The code was in the link of stackoverflow:
http://stackoverflow.com/questions/37841342/flink-with-kafka-consumer-doesnt-work
2016-06-22 11:28 GMT+02:00 Aljoscha Krettek :
> Once again, if you could please provide some example code that would allow
> us to figure out what the problem might be. Fro
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
wrote:
> Hi Robert, thanks for the answer
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 :
> Hi A
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 fi
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 :
> Hi,
> could you please provide a complete mi
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
wrote:
> Hi everyone,
> I wrote this post in stackoverflow
>
> http://stackoverflow.com/questions/37841342/
Hi everyone,
I wrote this post in stackoverflow
http://stackoverflow.com/questions/37841342/flink-with-kafka-consumer-doesnt-work
What's happening?
Thanks
