port kafka.serializer.StringEncoder;
import kafka.serializer. StringDecoder;
Regards
Jishnu Prathap
-Original Message-
From: Shao, Saisai [mailto:saisai.s...@intel.com]
Sent: Friday, February 06, 2015 6:41 AM
To: Eduardo Costa Alfaia; Sean Owen
Cc: user@spark.apache.org
Subject: RE: Error KafkaSt
Owen; user@spark.apache.org
Subject: Re: Error KafkaStream
Hi Shao,
When I changed to StringDecoder I’ve get this compiling error:
[error]
/sata_disk/workspace/spark-1.2.0/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/KafkaW
ordCount.scala:78: not found: type
ring.
> `DefaultDecoder` is to return Array[Byte], not String, so here class casting
> will meet error.
>
> Thanks
> Jerry
>
> -Original Message-
> From: Eduardo Costa Alfaia [mailto:e.costaalf...@unibs.it]
> Sent: Friday, February 6, 2015 12:04 AM
> T
: Eduardo Costa Alfaia [mailto:e.costaalf...@unibs.it]
Sent: Friday, February 6, 2015 12:04 AM
To: Sean Owen
Cc: user@spark.apache.org
Subject: Re: Error KafkaStream
I don’t think so Sean.
> On Feb 5, 2015, at 16:57, Sean Owen wrote:
>
> Is SPARK-4905 / https://github.com/apache/spark/pull/4
I don’t think so Sean.
> On Feb 5, 2015, at 16:57, Sean Owen wrote:
>
> Is SPARK-4905 / https://github.com/apache/spark/pull/4371/files the same
> issue?
>
> On Thu, Feb 5, 2015 at 7:03 AM, Eduardo Costa Alfaia
> wrote:
>> Hi Guys,
>> I’m getting this error in KafkaWordCount;
>>
>> TaskSetMa
Is SPARK-4905 / https://github.com/apache/spark/pull/4371/files the same issue?
On Thu, Feb 5, 2015 at 7:03 AM, Eduardo Costa Alfaia
wrote:
> Hi Guys,
> I’m getting this error in KafkaWordCount;
>
> TaskSetManager: Lost task 0.0 in stage 4095.0 (TID 1281, 10.20.10.234):
> java.lang.ClassCastExcep
