address comment

Davies Liu · Davies Liu · commit 97386b3debd5 · 2015-01-22T00:08:06.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
@@ -383,13 +383,15 @@ private[spark] object PythonRDD extends Logging {
         dataOut.write(bytes)
       }
     }
+
     def writeS(str: String) {
       if (str == null) {
         dataOut.writeInt(SpecialLengths.NULL)
       } else {
         writeUTF(str, dataOut)
       }
     }
+
     if (iter.hasNext) {
       val first = iter.next()
       val newIter = Seq(first).iterator ++ iter

Original file line number	Diff line number	Diff line change
`@@ -383,13 +383,15 @@ private[spark] object PythonRDD extends Logging {`
`383`	`383`	`dataOut.write(bytes)`
`384`	`384`	`}`
`385`	`385`	`}`
	`386`	`+`
`386`	`387`	`def writeS(str: String) {`
`387`	`388`	`if (str == null) {`
`388`	`389`	`dataOut.writeInt(SpecialLengths.NULL)`
`389`	`390`	`} else {`
`390`	`391`	`writeUTF(str, dataOut)`
`391`	`392`	`}`
`392`	`393`	`}`
	`394`	`+`
`393`	`395`	`if (iter.hasNext) {`
`394`	`396`	`val first = iter.next()`
`395`	`397`	`val newIter = Seq(first).iterator ++ iter`