Add log.

Marcelo Vanzin · Marcelo Vanzin · commit a68c2f2478f1 · 2017-07-21T15:27:51.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/executor/Executor.scala b/core/src/main/scala/org/apache/spark/executor/Executor.scala
@@ -502,6 +502,8 @@ private[spark] class Executor(
             }
             setTaskFinishedAndClearInterruptStatus()
             execBackend.statusUpdate(taskId, TaskState.FAILED, serializedTaskEndReason)
+          } else {
+            logInfo("Not reporting error to driver during JVM shutdown.")
           }
 
           // Don't forcibly exit unless the exception was inherently fatal, to avoid

Original file line number	Diff line number	Diff line change
`@@ -502,6 +502,8 @@ private[spark] class Executor(`
`502`	`502`	`}`
`503`	`503`	`setTaskFinishedAndClearInterruptStatus()`
`504`	`504`	`execBackend.statusUpdate(taskId, TaskState.FAILED, serializedTaskEndReason)`
	`505`	`+ } else {`
	`506`	`+ logInfo("Not reporting error to driver during JVM shutdown.")`
`505`	`507`	`}`
`506`	`508`
`507`	`509`	`// Don't forcibly exit unless the exception was inherently fatal, to avoid`