[hotfix] Remove redundant variable

kjperry · Jan 26, 2018 · d33aed3 · d33aed3
1 parent 66f6134
commit d33aed3
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java b/...-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java
@@ -52,10 +52,8 @@ public LeaderRetriever() {
 	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();
 			}