No, in general you can't make new RDDs in code running on the executors.
It looks like your properties file is a constant, why not process it at the
beginning of the job and broadcast the result?
On Fri, Sep 11, 2015 at 2:09 PM, Rachana Srivastava <
rachana.srivast...@markmonitor.com> wrote:
> H
Hello all,
Can we invoke JavaRDD while processing stream from Kafka for example.
Following code is throwing some serialization exception. Not sure if this is
feasible.
JavaStreamingContext jssc = new JavaStreamingContext(jsc,
Durations.seconds(5));
JavaPairReceiverInputDStream messages
