fix blocking unit tests by providing customized reporter

apache · Aug 31, 2018 · 60eec77 · 60eec77
1 parent 8d9495a
commit 60eec77
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala b/streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala
@@ -65,7 +65,8 @@ private[streaming] class FileBasedWriteAheadLog(
     "WriteAheadLogManager" + callerName.map(c => s" for $c").getOrElse("")
   }
   private val forkJoinPool = ThreadUtils.newForkJoinPool(threadpoolName, 20)
-  private val executionContext = ExecutionContext.fromExecutorService(forkJoinPool)
+  private val executionContext = ExecutionContext
+    .fromExecutorService(forkJoinPool, { e: Throwable => throw e })
 
   override protected def logName = {
     getClass.getName.stripSuffix("$") +