Thành phố Cuồng loạn

Nguồn dữ liệu: Lưu trữ ExecutionGraphInfo từ Flink Runtime Khi job dừng hoặc gặp lỗi, HistoryServerArchivist được gọi để lưu trữ: public interface HistoryServerArchivist { CompletableFuture<Acknowledge> archiveExecutionGraph(ExecutionGraphInfo executionGraphInfo); } Điểm gọi chính protected CompletableFuture<CleanupJobState&gt ...