This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 878b6b1 [FLINK-13892][hs] Harden HistoryServerTest
878b6b1 is described below
commit 878b6b19e8e23d69299aa00fb48fa19c3a9116c9
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Thu Sep 5 13:40:06 2019 +0200
[FLINK-13892][hs] Harden HistoryServerTest
---
.../runtime/webmonitor/history/HistoryServerArchiveFetcher.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
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 47888cd..fed220f 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
@@ -153,6 +153,7 @@ class HistoryServerArchiveFetcher {
continue;
}
boolean updateOverview = false;
+ int numFetchedArchives = 0;
for (FileStatus jobArchive :
jobArchives) {
Path jobArchivePath =
jobArchive.getPath();
String jobID =
jobArchivePath.getName();
@@ -200,7 +201,7 @@ class HistoryServerArchiveFetcher {
}
}
updateOverview
= true;
-
numArchivedJobs.countDown();
+
numFetchedArchives++;
} catch (IOException e)
{
LOG.error("Failure while fetching/processing job archive for job {}.", jobID,
e);
// Make sure we
attempt to fetch the archive again
@@ -224,6 +225,9 @@ class HistoryServerArchiveFetcher {
}
if (updateOverview) {
updateJobOverview(webOverviewDir, webDir);
+ for (int x = 0; x <
numFetchedArchives; x++) {
+
numArchivedJobs.countDown();
+ }
}
}
} catch (Exception e) {
