Hi,
I am not sure if this is useful, I once had similar issue.
Are you including storm-core dependency in your project? flink-storm
dependency doesn't need any specific storm-core dependency.
Just including flink-storm and removing storm-core dependency worked for me.
This has more information,
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() {
