Can you show more of your code inside the while loop ?
Which version of Spark / Kinesis do you use ?
Thanks
On Mon, Apr 25, 2016 at 4:04 AM, Selvam Raman wrote:
> I am reading a data from Kinesis stream (merging shard values with union
> stream) to spark streaming. then
I am reading a data from Kinesis stream (merging shard values with union
stream) to spark streaming. then doing the following code to push the data
to DB.
splitCSV.foreachRDD(new VoidFunction2,Time>()
{
private static final long serialVersionUID = 1L;
public void