diff options
author | zsxwing <zsxwing@gmail.com> | 2015-03-30 22:10:49 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-03-30 22:10:49 -0700 |
commit | 56775571cb938c819e5f7c3d49c5dd416ed034cb (patch) | |
tree | e0a26241c46c3e72038fc1866ec9fefa1ccc08c8 /core | |
parent | b8ff2bc61c9835867f56afa1860ab5eb727c4a58 (diff) | |
download | spark-56775571cb938c819e5f7c3d49c5dd416ed034cb.tar.gz spark-56775571cb938c819e5f7c3d49c5dd416ed034cb.tar.bz2 spark-56775571cb938c819e5f7c3d49c5dd416ed034cb.zip |
[SPARK-5124][Core] Move StopCoordinator to the receive method since it does not require a reply
Hotfix for #4588
cc rxin
Author: zsxwing <zsxwing@gmail.com>
Closes #5283 from zsxwing/hotfix and squashes the following commits:
cf3e5a7 [zsxwing] Move StopCoordinator to the receive method since it does not require a reply
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala b/core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala index f748f394d1..17055e2f22 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala @@ -156,14 +156,16 @@ private[spark] object OutputCommitCoordinator { override val rpcEnv: RpcEnv, outputCommitCoordinator: OutputCommitCoordinator) extends RpcEndpoint with Logging { + override def receive: PartialFunction[Any, Unit] = { + case StopCoordinator => + logInfo("OutputCommitCoordinator stopped!") + stop() + } + override def receiveAndReply(context: RpcCallContext): PartialFunction[Any, Unit] = { case AskPermissionToCommitOutput(stage, partition, taskAttempt) => context.reply( outputCommitCoordinator.handleAskPermissionToCommit(stage, partition, taskAttempt)) - case StopCoordinator => - logInfo("OutputCommitCoordinator stopped!") - context.reply(true) - stop() } } } |