From 743b571d2a27796fe2a57c0db2e384121cc63150 Mon Sep 17 00:00:00 2001 From: zhagnlu <1542303831@qq.com> Date: Sat, 16 Jan 2016 13:41:44 +0800 Subject: [PATCH] fix a bug --- core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala | 1 + 1 file changed, 1 insertion(+) 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 index f12e2dfafa19d..7321d745b4061 100644 --- a/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala +++ b/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala @@ -276,6 +276,7 @@ private[spark] class PythonRunner( // Serialized command: dataOut.writeInt(command.length) dataOut.write(command) + dataOut.flush() // Data values PythonRDD.writeIteratorToStream(inputIterator, dataOut) dataOut.writeInt(SpecialLengths.END_OF_DATA_SECTION)