TopologyBuilder throws java.lang.ExceptionInInitializerError

Hi, I am converting a storm topology to Flink-storm topology using the flink-storm dependency. When I run my code the FlinkTopologyBuilder eventually calls createTopology method in TopologyBuilder and throws the error at the following highlighted line:- public StormTopology createTopology() {

Query regarding using storm topology in Flink

Hi, I am trying to run locally a storm topology in flink using the flink-storm library , but I get the following error Exception in thread "main" java.lang.NoClassDefFoundError: scala/concurrent/ExecutionContext at org.apache.flink.storm.api.FlinkLocalCluster.(FlinkLocalCluster.java:54) at