flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jerry Peng <jerry.boyang.p...@gmail.com>
Subject question on flink-storm-examples
Date Tue, 01 Sep 2015 19:40:12 GMT

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?



View raw message