Once again, if you could please provide some example code that would allow us to figure out what the problem might be. From just looking at the logs it is not obvious, at the end the job seems to be running.
On Wed, 22 Jun 2016 at 11:06 Adrian Portabales <[email protected]> wrote: > 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 <[email protected]>: > > > 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 < > > [email protected]> 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 <[email protected]>: > > > > > > > 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 < > > > [email protected] > > > > > > > > > wrote: > > > > > > > > > Hi everyone, > > > > > I wrote this post in stackoverflow > > > > > > > > > > > > > > > > > > > > http://stackoverflow.com/questions/37841342/flink-with-kafka-consumer-doesnt-work > > > > > > > > > > What's happening? > > > > > > > > > > Thanks > > > > > > > > > > > > > > >
