bq. return new
Tuple2(new ImmutableBytesWritable(), put);
I don't think Put is serializable.
FYI
On Fri, Jun 12, 2015 at 6:40 AM, Vamshi Krishna
wrote:
> Hi I am trying to write data that is produced from kafka commandline
> producer for
Hi I am trying to write data that is produced from kafka commandline
producer for some topic. I am facing problem and unable to proceed. Below
is my code which I am creating a jar and running through spark-submit on
spark-shell. Am I doing wrong inside foreachRDD() ? What is wrong with
SparkKafkaD
