dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1099978500
##########
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java:
##########
@@ -103,47 +124,76 @@ public ArchiveEventType getType() {
}
private static final Logger LOG =
LoggerFactory.getLogger(HistoryServerArchiveFetcher.class);
-
private static final JsonFactory jacksonFactory = new JsonFactory();
private static final ObjectMapper mapper =
JacksonMapperFactory.createObjectMapper();
private static final String JSON_FILE_ENDING = ".json";
private final List<HistoryServer.RefreshLocation> refreshDirs;
+ private final List<ArchiveEvent> events;
private final Consumer<ArchiveEvent> jobArchiveEventListener;
private final boolean processExpiredArchiveDeletion;
private final boolean processBeyondLimitArchiveDeletion;
private final int maxHistorySize;
/** Cache of all available jobs identified by their id. */
private final Map<Path, Set<String>> cachedArchivesPerRefreshDirectory;
+ /** Cache of all unzipped jobs. key: jobID */
+ private final LoadingCache<String, Boolean> unzippedJobCache;
Review Comment:
> What does the boolean value stand for?
The boolean value in `unzippedJobCache ` means whether the unzip was
successful
I just want to use removalListener function of `Guava cache`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
