diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-26 12:07:59 -0800 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-26 12:07:59 -0800 |
commit | 73697e289174583fe7b0e829eb8387d1a1aa8721 (patch) | |
tree | b5106c49eca9be50f0e7586b0aa0a9eb21d8177c | |
parent | 9a046e30ac6013fc74f60892f73086e17e14fd3e (diff) | |
download | spark-73697e289174583fe7b0e829eb8387d1a1aa8721.tar.gz spark-73697e289174583fe7b0e829eb8387d1a1aa8721.tar.bz2 spark-73697e289174583fe7b0e829eb8387d1a1aa8721.zip |
Fix overly large thread names in PySpark
-rw-r--r-- | core/src/main/scala/spark/api/python/PythonRDD.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/api/python/PythonRDD.scala b/core/src/main/scala/spark/api/python/PythonRDD.scala index 8c73477384..9b4d54ab4e 100644 --- a/core/src/main/scala/spark/api/python/PythonRDD.scala +++ b/core/src/main/scala/spark/api/python/PythonRDD.scala @@ -51,7 +51,7 @@ private[spark] class PythonRDD[T: ClassManifest]( val env = SparkEnv.get // Start a thread to print the process's stderr to ours - new Thread("stderr reader for " + command) { + new Thread("stderr reader for " + pythonExec) { override def run() { for (line <- Source.fromInputStream(proc.getErrorStream).getLines) { System.err.println(line) @@ -60,7 +60,7 @@ private[spark] class PythonRDD[T: ClassManifest]( }.start() // Start a thread to feed the process input from our parent's iterator - new Thread("stdin writer for " + command) { + new Thread("stdin writer for " + pythonExec) { override def run() { SparkEnv.set(env) val out = new PrintWriter(proc.getOutputStream) |