[hotfix][hs] Deduplicate variables

derekm · Oct 16, 2019 · 41492c4 · 41492c4
1 parent 59dd855
commit 41492c4
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...rc/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java b/...rc/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
@@ -152,7 +152,6 @@ public void run() {
  if (jobArchives == null) {
  continue;
  }
- boolean updateOverview = false;
  int numFetchedArchives = 0;
  for (FileStatus jobArchive : jobArchives) {
  Path jobArchivePath = jobArchive.getPath();
@@ -200,7 +199,6 @@ public void run() {
  fw.flush();
  }
  }
- updateOverview = true;
  numFetchedArchives++;
  } catch (IOException e) {
  LOG.error("Failure while fetching/processing job archive for job {}.", jobID, e);
@@ -223,7 +221,7 @@ public void run() {
  }
  }
  }
- if (updateOverview) {
+ if (numFetchedArchives > 0) {
  updateJobOverview(webOverviewDir, webDir);
  for (int x = 0; x < numFetchedArchives; x++) {
  numArchivedJobs.countDown();