diff options
Diffstat (limited to 'common/network-shuffle')
| -rw-r--r-- | common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java index 1cc0fb65d7..1270cef621 100644 --- a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java +++ b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockHandler.java @@ -113,7 +113,8 @@ public class ExternalShuffleBlockHandler extends RpcHandler { } } else if (msgObj instanceof RegisterExecutor) { - final Timer.Context responseDelayContext = metrics.registerExecutorRequestLatencyMillis.time(); + final Timer.Context responseDelayContext = + metrics.registerExecutorRequestLatencyMillis.time(); try { RegisterExecutor msg = (RegisterExecutor) msgObj; checkAuth(client, msg.appId); |