i working on spark streaming kinesis on emr. 25 days streaming fine running every minute , precessing around 1000 records. have written job in scala today when looked @ master ui saw spark not processing recorda , had queued 40 jobs 0 records. stuck in reading records kinesis.
has experienced issue earlier. using spark 1.6