dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1100910581
##########
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java:
##########
@@ -75,16 +86,26 @@ class HistoryServerArchiveFetcher {
/** Possible job archive operations in history-server. */
public enum ArchiveEventType {
- /** Job archive was found in one refresh location and created in
history server. */
+ /** Archived job file was found in one refresh location and downloaded
in history server. */
+ DOWNLOADED,
+ /** Unzipped Job archive was reloaded. */
+ RELOADED,
+ /**
+ * Archived job file was unzipped and Unzipped Job archive was created
in history server.
+ */
CREATED,
+ /** Unzipped Job archive was deleted in history server. */
+ CLEANED,
/**
- * Job archive was deleted from one of refresh locations and deleted
from history server.
+ * Archived job file and Unzipped Job archive was deleted from one of
refresh locations and
+ * deleted from history server.
*/
- DELETED
+ DELETED,
}
/** Representation of job archive event. */
public static class ArchiveEvent {
+
Review Comment:
`ArchiveEvent` is still used for testing
--
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]
