Manuel Laflamme created SPARK-2343:
--------------------------------------
Summary: QueueInputDStream with oneAtATime=false does not dequeue
items
Key: SPARK-2343
URL: https://issues.apache.org/jira/browse/SPARK-2343
Project: Spark
Issue Type: Bug
Components: Streaming
Affects Versions: 1.0.0, 0.9.1, 0.9.0
Reporter: Manuel Laflamme
Priority: Minor
QueueInputDStream does not dequeue items when used with the oneAtATime flag
disabled. The same items are reprocessed for every batch.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
