This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5501858245cfe8700f9ca5f081da13fb4f73154d
Author: Chesnay Schepler <ches...@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();
