RE: cannot be cast to java.lang.String

2015-03-26 Thread Jordi Blasi Uribarri
step. Thanks a lot, Jordi -Mensaje original- De: Jordi Blasi Uribarri [mailto:jbl...@nextel.es] Enviado el: jueves, 26 de marzo de 2015 9:21 Para: dev@samza.apache.org Asunto: RE: cannot be cast to java.lang.String I am not sure of understanding what you want to say. Does this mean

RE: cannot be cast to java.lang.String

2015-03-26 Thread Jordi Blasi Uribarri
oles, 25 de marzo de 2015 16:59 Para: dev@samza.apache.org Asunto: Re: cannot be cast to java.lang.String I think this is a bit specific to Samza. In the KafkaSystemProducer class, it does something like this: envelope.getMessage.asInstanceOf[Array[Byte]] and not just 'byte[]'. This is wh

Re: cannot be cast to java.lang.String

2015-03-25 Thread Chinmay Soman
o el: lunes, 23 de marzo de 2015 17:55 > Para: dev@samza.apache.org > Asunto: Re: cannot be cast to java.lang.String > > Hey Jordi, > > This is because you're sending String and not json in your output topic. > Try setting string on the output stream as well (if you h

RE: cannot be cast to java.lang.String

2015-03-25 Thread Jordi Blasi Uribarri
non$1.run(ThreadJob.scala:42) > > Thanks. > > Jordi > -Mensaje original- > De: Chinmay Soman [mailto:chinmay.cere...@gmail.com] > Enviado el: lunes, 23 de marzo de 2015 17:36 > Para: dev@samza.apache.org > Asunto: Re: cannot be cast to java.lang.String > >

Re: cannot be cast to java.lang.String

2015-03-23 Thread Chinmay Soman
ob.scala:42) > > Thanks. > > Jordi > -Mensaje original- > De: Chinmay Soman [mailto:chinmay.cere...@gmail.com] > Enviado el: lunes, 23 de marzo de 2015 17:36 > Para: dev@samza.apache.org > Asunto: Re: cannot be cast to java.lang.String > > Have yo

RE: cannot be cast to java.lang.String

2015-03-23 Thread Jordi Blasi Uribarri
original- De: Chinmay Soman [mailto:chinmay.cere...@gmail.com] Enviado el: lunes, 23 de marzo de 2015 17:36 Para: dev@samza.apache.org Asunto: Re: cannot be cast to java.lang.String Have you tried setting this : systems.kafka.streams.syslog.samza.msg.serde=string // And assuming you've de

Re: cannot be cast to java.lang.String

2015-03-23 Thread Chinmay Soman
ilto:chinmay.cere...@gmail.com] > Enviado el: lunes, 23 de marzo de 2015 17:16 > Para: dev@samza.apache.org > Asunto: Re: cannot be cast to java.lang.String > > Hey Jordi, > > I see 3 different stream names. > > 1. new SystemStream("kafka", "beste");

RE: cannot be cast to java.lang.String

2015-03-23 Thread Jordi Blasi Uribarri
nd I am testing "beste" with an internal application specifically designed. I am not sure about the kafka part. Thanks. Jordi -Mensaje original- De: Chinmay Soman [mailto:chinmay.cere...@gmail.com] Enviado el: lunes, 23 de marzo de 2015 17:16 Para: dev@samza.apache.org Asunto:

Re: cannot be cast to java.lang.String

2015-03-23 Thread Chinmay Soman
Hey Jordi, I see 3 different stream names. 1. new SystemStream("kafka", "beste"); 2. task.inputs=kafka.syslog 3. systems.kafka.streams.frogain.samza.msg.serde=json Just for a sanity check, can you double check you're setting the config params for the correct stream ? On Mon, Mar 23, 2015 at