Please post a minimal complete code example of what you are talking about
On Thu, Dec 15, 2016 at 6:00 PM, Michael Nguyen
wrote:
> I have the following sequence of Spark Java API calls (Spark 2.0.2):
>
> Kafka stream that is processed via a map function, which returns
I have the following sequence of Spark Java API calls (Spark 2.0.2):
1. Kafka stream that is processed via a map function, which returns the
string value from tuple2._2() for JavaDStream as in
return tuple2._2();
1.
The returned JavaDStream is then processed by foreachPartition,