[hotfix] Remove redundant variable
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d33aed3f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d33aed3f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d33aed3f Branch: refs/heads/master Commit: d33aed3f48c8a62e18457a882e528898aaefccaa Parents: 66f6134 Author: gyao <[email protected]> Authored: Mon Jan 22 11:42:51 2018 +0100 Committer: Till Rohrmann <[email protected]> Committed: Fri Jan 26 13:50:24 2018 +0100 ---------------------------------------------------------------------- .../flink/runtime/webmonitor/retriever/LeaderRetriever.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d33aed3f/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java b/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java index e9ea90e..6a2d5c5 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java @@ -52,10 +52,8 @@ public class LeaderRetriever implements LeaderRetrievalListener { public Optional<Tuple2<String, UUID>> getLeaderNow() throws Exception { CompletableFuture<Tuple2<String, UUID>> leaderFuture = this.atomicLeaderFuture.get(); if (leaderFuture != null) { - CompletableFuture<Tuple2<String, UUID>> currentLeaderFuture = leaderFuture; - - if (currentLeaderFuture.isDone()) { - return Optional.of(currentLeaderFuture.get()); + if (leaderFuture.isDone()) { + return Optional.of(leaderFuture.get()); } else { return Optional.empty(); }
