You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/10/16 13:11:25 UTC
[flink] 01/04: [hotfix][hs] Deduplicate variables
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9d62ebfb5c0a827f679db38f2b1f921b03069eca
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Oct 8 11:26:55 2019 +0200
[hotfix][hs] Deduplicate variables
---
.../flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
index fed220f..4cd8b89 100644
--- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
+++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
@@ -152,7 +152,6 @@ class HistoryServerArchiveFetcher {
if (jobArchives == null) {
continue;
}
- boolean updateOverview = false;
int numFetchedArchives = 0;
for (FileStatus jobArchive : jobArchives) {
Path jobArchivePath = jobArchive.getPath();
@@ -200,7 +199,6 @@ class HistoryServerArchiveFetcher {
fw.flush();
}
}
- updateOverview = true;
numFetchedArchives++;
} catch (IOException e) {
LOG.error("Failure while fetching/processing job archive for job {}.", jobID, e);
@@ -223,7 +221,7 @@ class HistoryServerArchiveFetcher {
}
}
}
- if (updateOverview) {
+ if (numFetchedArchives > 0) {
updateJobOverview(webOverviewDir, webDir);
for (int x = 0; x < numFetchedArchives; x++) {
numArchivedJobs.countDown();