akka.stream.materializer exception

2018-07-20 Thread Rad Rad
Hi, I have a problem when running streaming Flink from jar file using CLI, the program works fine if it runs from IDE? The main exception is [1] When I search for this exception, I tried to solve it by adding akka dependencies to my pom.xml file as [2] and maven shaded plugin for jar execution

akka.stream.materializer exception

2018-07-13 Thread Rad Rad
Hi, I have a jar file that subscribes streaming data from Kafka and then executes some Flink queries. When the program runs locally, it works fine. But, when I run the jar file, I got these exceptions which sound that akka.stream.materializer causes the problem, I added akka.stream dependencies