Hi Robert, thanks for the answer. How do you test if data is being read from Kafka or not? -Tested with kafka consumer script
What are the taskmanager logs saying? -http://pastebin.com/AA2MwW5W I think the problem is with the line 89. Thanks! 2016-06-21 18:17 GMT+02:00 Robert Metzger <rmetz...@apache.org>: > Hi Adrian, > > you need to provide a bit more information than this to understand the > problem. > What are the taskmanager logs saying? > How do you test if data is being read from Kafka or not? > > On Fri, Jun 17, 2016 at 11:36 AM, Adrian Portabales < > adrianportaba...@gmail.com> wrote: > > > Other jobs works fine in Flink (like batch wordcount) but this doesn't. > > I use "bin/flink run -m analytics1:6123 -c KafkaWordCountFlink > > ../benchmark_Spark-Flink-assembly-1.0.jar wordCount2" > > > > Thanks > > Adrian > > > > 2016-06-17 11:10 GMT+02:00 Aljoscha Krettek <aljos...@apache.org>: > > > > > Hi, > > > could you please provide a complete minimal example and the commands > that > > > you use to start the cluster and run the job? > > > > > > Cheers, > > > Aljoscha > > > > > > On Fri, 17 Jun 2016 at 10:53 Adrian Portabales < > > adrianportaba...@gmail.com > > > > > > > wrote: > > > > > > > Hi everyone, > > > > I wrote this post in stackoverflow > > > > > > > > > > > > > > http://stackoverflow.com/questions/37841342/flink-with-kafka-consumer-doesnt-work > > > > > > > > What's happening? > > > > > > > > Thanks > > > > > > > > > >
