Mocking Inner Singleton objects for Scala Tests using MockitoSugar This is a special case of testing when you need to test a type but dependencies come in all shapes and sizes. In order to test your class, you might not have any control on the dependencies. This is specially true when your dependencies are from… Continue reading »
![Apache Flink – Class Not found [org/apache/flink/streaming/api/scala/DataStream]](http://www.alternatestack.com/wp-content/uploads/2018/09/Screen-Shot-2018-09-16-at-5.29.04-PM-200x140.png)
Apache Flink – Class Not found [org/apache/flink/streaming/api/scala/DataStream] If you are developing a Flink app following examples on the web, you can most likely encounter the following error: Generally, the problem is resolved by correctly setting the source folder in a scala project in IntelliJ but the weird thing is that it is happening for a… Continue reading »
Apache Flink – Change Port for web front end Apache Flink runs the dashboard on port 8081. Since this is a common port there might be conflict with some other services running on the same machines. You might encounter this scenario especially during development when many services are running on the your development machine. But… Continue reading »
IntelliJ & Scala – Could not load main class This is one of the most common error we see when we get new code from a source repository. We might also see it when we create a new Scala project. As we run the application, the console shows could not load main class The solution… Continue reading »
IntelliJ – Add New Scala Class Option – Not Available You might get into this problem every time a new Scala project is created. By default, the support of Scala is not available. So when you right click your src folder to add Scala Class, you might be disappointed to see no option for adding… Continue reading »
SBT 1.0 and IntelliJ IDEA Scala plugin – needs update I had to do a few updates to my Scala development tools, which hit me with a surprise when I tried to build one of Scala SBT applications. The build failed with misleading error messages. Digging deeper, I could find this message in one of… Continue reading »
Kafka Streams – Interactive Queries (Intra Application Instance) Kafka Streams application need to maintain KTables in an internal application store. It maintains the store using RocksDB. It even allows to query this store during application lifecycle anywhere from the application parts. Let’s first create a simple application KafkaStreamsInteractiveQueriesApp. It is a simple Scala Application. In… Continue reading »
Packaging configurations outside Jars with SBT Native Plugin In this post we are going to see how we can separately package any files (especially config and log configuration) out of packaged jar when we use sbt native packager for packaging our scala application. Here we are building from our last post. In order to use… Continue reading »
avro-tools in Scala Projects – Don’t… In this post we are going to discuss how Avro-tools dependency can mess up your logging in a Scala project. Let’s create a sample Scala SBT project. We update the build.sbt as follows: Here are we adding dependencies for logback in addition to avro-tools dependency. Let’s create a simple… Continue reading »
Play Framework and CORS with Angular2 Client(Cross Origin Resource Sharing) Although Play framework allows us to write complete web application including UI. But we can just keep our REST based HTTP service in Play Framework and access them from any other application hosted on another server. But as soon as you do it, you start… Continue reading »