Github user mengxr commented on a diff in the pull request:
https://github.com/apache/spark/pull/22085#discussion_r211359959
--- Diff:
core/src/main/scala/org/apache/spark/api/python/PythonRunner.scala ---
@@ -381,6 +465,20 @@ private[spark] abstract class BasePythonRunner[IN,
OUT](
}
}
}
+
+ def writeUTF(str: String, dataOut: DataOutputStream) {
+ val bytes = str.getBytes(StandardCharsets.UTF_8)
--- End diff --
nit: `UTF_8` or always use `StandardCharsets`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
