LuciferYang commented on a change in pull request #35566:
URL: https://github.com/apache/spark/pull/35566#discussion_r809715204
##########
File path:
core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala
##########
@@ -65,10 +64,6 @@ private[spark] class CoarseGrainedExecutorBackend(
var executor: Executor = null
@volatile var driver: Option[RpcEndpointRef] = None
- // If this CoarseGrainedExecutorBackend is changed to support multiple
threads, then this may need
- // to be changed so that we don't share the serializer instance across
threads
- private[this] val ser: SerializerInstance =
env.closureSerializer.newInstance()
Review comment:
[SPARK-3386](https://issues.apache.org/jira/browse/SPARK-3386) move
`ser` out of `receive` method, it used for deserialize of `TaskDescription`,
but SPARK-17931 change to use `TaskDescription` do this work
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
