-
- Downloads
[SPARK-11731][STREAMING] Enable batching on Driver WriteAheadLog by default
Using batching on the driver for the WriteAheadLog should be an improvement for all environments and use cases. Users will be able to scale to much higher number of receivers with the BatchedWriteAheadLog. Therefore we should turn it on by default, and QA it in the QA period. I've also added some tests to make sure the default configurations are correct regarding recent additions: - batching on by default - closeFileAfterWrite off by default - parallelRecovery off by default Author: Burak Yavuz <brkyvz@gmail.com> Closes #9695 from brkyvz/enable-batch-wal.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/util/WriteAheadLogUtils.scala 1 addition, 1 deletion.../org/apache/spark/streaming/util/WriteAheadLogUtils.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaWriteAheadLogSuite.java 1 addition, 0 deletions...va/org/apache/spark/streaming/JavaWriteAheadLogSuite.java
- streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockTrackerSuite.scala 7 additions, 2 deletions...rg/apache/spark/streaming/ReceivedBlockTrackerSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/util/WriteAheadLogSuite.scala 23 additions, 1 deletion.../org/apache/spark/streaming/util/WriteAheadLogSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/util/WriteAheadLogUtilsSuite.scala 16 additions, 3 deletions...apache/spark/streaming/util/WriteAheadLogUtilsSuite.scala
Loading
Please register or sign in to comment