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)