capture the exception in python write thread

Davies Liu · Davies Liu · commit 139b0db4ad89 · 2015-02-12T14:28:55.000-08:00
diff --git a/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala b/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala
@@ -202,7 +202,7 @@ private[spark] class PythonRDD(
       this.interrupt()
     }
 
-    override def run(): Unit = Utils.logUncaughtExceptions {
+    override def run(): Unit = Utils.tryLog {
       try {
         val stream = new BufferedOutputStream(worker.getOutputStream, bufferSize)
         val dataOut = new DataOutputStream(stream)

Original file line number	Diff line number	Diff line change
`@@ -202,7 +202,7 @@ private[spark] class PythonRDD(`
`202`	`202`	`this.interrupt()`
`203`	`203`	`}`
`204`	`204`
`205`		`- override def run(): Unit = Utils.logUncaughtExceptions {`
	`205`	`+ override def run(): Unit = Utils.tryLog {`
`206`	`206`	`try {`
`207`	`207`	`val stream = new BufferedOutputStream(worker.getOutputStream, bufferSize)`
`208`	`208`	`val dataOut = new DataOutputStream(stream)`