Hello, I have some questions regarding how to run one of the flink-storm-examples, the WordCountTopology. How should I run the job? On github its says I should just execute bin/flink run example.jar but when I execute:
bin/flink run WordCount-StormTopology.jar nothing happens. What am I doing wrong? and How can I run the WordCounttopology via StormWordCountRemoteBySubmitter? Also why did you guys get rid of the KafkaSource class? What is the API now for subscribing to a kafka source? Best, Jerry
