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 > > > > > >
