[hotfix] Fix typo in AkkaRpcService

上级 a72b55ea
......@@ -336,9 +336,9 @@ public class AkkaRpcService implements RpcService {
LOG.info("Stopping Akka RPC service.");
final CompletableFuture<Terminated> actorSytemTerminationFuture = FutureUtils.toJava(actorSystem.terminate());
final CompletableFuture<Terminated> actorSystemTerminationFuture = FutureUtils.toJava(actorSystem.terminate());
actorSytemTerminationFuture.whenComplete(
actorSystemTerminationFuture.whenComplete(
(Terminated ignored, Throwable throwable) -> {
synchronized (lock) {
actors.clear();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册