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
; > I get an exception like this: > > 22 mar 2015 23:16:25 ERROR SamzaContainer - Caught exception in process > loop. > java.lang.ClassCastException: [B cannot be cast to java.lang.String > at samzafroga.job1.process(job1.java:19) >

cannot be cast to java.lang.String

2015-03-23 Thread Jordi Blasi Uribarri
String msg = (String)envelope.getMessage(); I get an exception like this: 22 mar 2015 23:16:25 ERROR SamzaContainer - Caught exception in process loop. java.lang.ClassCastException: [B cannot be cast to java.lang.String at samzafroga.job1.process(job1