Repository: spark
Updated Branches:
refs/heads/branch-1.6 1fbfc1b48 -> aa7194de3
[SPARK-11639][STREAMING][FLAKY-TEST] Implement BlockingWriteAheadLog for
testing the BatchedWriteAheadLog
Several elements could be drained if the main thread is not fast enough.
zsxwing warned me about a simila
Repository: spark
Updated Branches:
refs/heads/master 529a1d338 -> 27029bc8f
[SPARK-11639][STREAMING][FLAKY-TEST] Implement BlockingWriteAheadLog for
testing the BatchedWriteAheadLog
Several elements could be drained if the main thread is not fast enough.
zsxwing warned me about a similar pr