We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 252238d commit f8535dcCopy full SHA for f8535dc
core/src/main/scala/org/apache/spark/util/Utils.scala
@@ -57,7 +57,7 @@ private[spark] object Utils extends Logging {
57
new File(sparkHome + File.separator + "bin", which + suffix)
58
}
59
60
- /** Serialize an object using the closure serializer. **/
+ /** Serialize an object using the closure serializer. */
61
def serializeTaskClosure[T: ClassTag](o: T): Array[Byte] = {
62
val ser = SparkEnv.get.closureSerializer.newInstance()
63
ser.serialize(o).array()
0 commit comments