Skip to content

Commit 071d193

Browse files
committed
refactored post-SPARK-1772
1 parent 1a6a35e commit 071d193

File tree

3 files changed

+3
-46
lines changed

3 files changed

+3
-46
lines changed

core/src/main/scala/org/apache/spark/executor/Executor.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import org.apache.spark._
2929
import org.apache.spark.deploy.SparkHadoopUtil
3030
import org.apache.spark.scheduler._
3131
import org.apache.spark.storage.{StorageLevel, TaskResultBlockId}
32-
import org.apache.spark.util.{UncaughtExceptionHandler, AkkaUtils, Utils}
32+
import org.apache.spark.util.{AkkaUtils, Utils}
3333

3434
/**
3535
* Spark executor used with Mesos, YARN, and the standalone scheduler.

core/src/main/scala/org/apache/spark/util/UncaughtExceptionHandler.scala

Lines changed: 0 additions & 44 deletions
This file was deleted.

core/src/main/scala/org/apache/spark/util/Utils.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ import tachyon.client.{TachyonFile,TachyonFS}
4040

4141
import org.apache.spark.{Logging, SecurityManager, SparkConf, SparkException}
4242
import org.apache.spark.deploy.SparkHadoopUtil
43+
import org.apache.spark.executor.ExecutorUncaughtExceptionHandler
4344
import org.apache.spark.serializer.{DeserializationStream, SerializationStream, SerializerInstance}
4445

4546
/**
@@ -786,7 +787,7 @@ private[spark] object Utils extends Logging {
786787
try {
787788
block
788789
} catch {
789-
case t: Throwable => UncaughtExceptionHandler.uncaughtException(Thread.currentThread, t)
790+
case t: Throwable => ExecutorUncaughtExceptionHandler.uncaughtException(t)
790791
}
791792
}
792793

0 commit comments

Comments
 (0)