apache/spark — pull request #1285 by mlaflamm (2014-07-02 16:55:08+00:00)
Title: [STREAMING] SPARK-2343: Fix QueueInputDStream with oneAtATime false

Fix QueueInputDStream which was not removing dequeued items when used with the oneAtATime flag disabled.