Re: Facing error while running Hands-in training example “writing to Apache Kafka”

Hi Ashutosh, I used the same connector to read from the Kafka, it is working fine. but writing has the mentioned issue! On Wed, Jun 1, 2016 at 12:37 PM, Ashutosh Kumar wrote: > How are you packaging and deploying your jar ? I have tested with flink > and kafka .9 . It

Re: Facing error while running Hands-in training example “writing to Apache Kafka”

I run it in Eclipse IDE, On Wed, Jun 1, 2016 at 12:37 PM, Ashutosh Kumar wrote: > How are you packaging and deploying your jar ? I have tested with flink > and kafka .9 . It works fine for me . > > Thanks > Ashutosh > > On Wed, Jun 1, 2016 at 3:37 PM, ahmad Sa P

Re: Facing error while running Hands-in training example “writing to Apache Kafka”

How are you packaging and deploying your jar ? I have tested with flink and kafka .9 . It works fine for me . Thanks Ashutosh On Wed, Jun 1, 2016 at 3:37 PM, ahmad Sa P wrote: > I did test it with Kafka 0.9.0.1, still the problem exists! > > On Wed, Jun 1, 2016 at 11:50 AM,

Re: Facing error while running Hands-in training example “writing to Apache Kafka”

I did test it with Kafka 0.9.0.1, still the problem exists! On Wed, Jun 1, 2016 at 11:50 AM, Aljoscha Krettek wrote: > The Flink Kafka Consumer was never tested with Kafka 0.10, could you try > it with 0.9. The 0.10 release is still very new and we have yet to provide > a

Re: Facing error while running Hands-in training example “writing to Apache Kafka”

This is unrelated to joda time or Kryo, that's just an info message in the log. What version of Flink and Kafka are you using? On Wed, 1 Jun 2016 at 07:02 arpit srivastava wrote: > Flink uses kryo serialization which doesn't support joda time object > serialization. > >

Re: Facing error while running Hands-in training example “writing to Apache Kafka”

Flink uses kryo serialization which doesn't support joda time object serialization. Use java.util.date or you have to change kryo. Thanks, Arpit On Tue, May 31, 2016 at 11:18 PM, ahmad Sa P wrote: > Hi > I have a problem at running a sample code from the hands-in examples

Facing error while running Hands-in training example “writing to Apache Kafka”

Hi I have a problem at running a sample code from the hands-in examples of Apache Flink, I used the following code to send output of a stream to already running Apache Kafka, and get the below error. Could anyone tell me what is going wrong? Best regards Ahmad public class RideCleansing {