GitHub user arunmahadevan opened a pull request:
https://github.com/apache/spark/pull/21207
SPARK-24136: Fix MemoryStreamDataReader.next to skip sleeping if record is
available
## What changes were proposed in this pull request?
Avoid unnecessary sleep (10 ms) in each invocation of
MemoryStreamDataReader.next.
## How was this patch tested?
Ran ContinuousSuite from IDE.
Please review http://spark.apache.org/contributing.html before opening a
pull request.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/arunmahadevan/spark memorystream
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/21207.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #21207
----
commit 4daa548c470a6e5d5de477a10661c4d838c520f5
Author: Arun Mahadevan <arunm@...>
Date: 2018-05-01T16:23:59Z
SPARK-24136: Minor fix in MemoryStreamDataReader to skip sleeping if record
is available.
----
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
