This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6ffb7edea75 [FLINK-38189][core][python] Introduce
RowFieldExtractorSchema for Row field serialization (#27353)
add 8c5735f0357 [FLINK-38845][runtime] Add ArchivedApplicationStore to
manage terminated applications
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 48 +--
.../generated/job_manager_configuration.html | 48 +--
.../application/ApplicationClusterEntryPoint.java | 8 +-
.../flink/configuration/JobManagerOptions.java | 96 ++++-
.../runtime/application/AbstractApplication.java | 21 ++
.../ApplicationStatusListener.java} | 22 +-
.../runtime/application/ArchivedApplication.java | 11 +-
...nfoStore.java => ArchivedApplicationStore.java} | 55 +--
.../flink/runtime/dispatcher/Dispatcher.java | 309 +++++++++++-----
.../runtime/dispatcher/DispatcherServices.java | 15 +-
.../dispatcher/FileArchivedApplicationStore.java | 384 ++++++++++++++++++++
.../dispatcher/FileExecutionGraphInfoStore.java | 326 -----------------
...re.java => MemoryArchivedApplicationStore.java} | 94 +++--
.../dispatcher/PartialDispatcherServices.java | 10 +-
...atcherServicesWithJobPersistenceComponents.java | 6 +-
.../runtime/entrypoint/ClusterEntrypoint.java | 18 +-
.../entrypoint/SessionClusterEntrypoint.java | 30 +-
...tDispatcherResourceManagerComponentFactory.java | 6 +-
.../DispatcherResourceManagerComponentFactory.java | 4 +-
.../messages/webmonitor/ApplicationDetails.java | 6 +-
.../webmonitor/ApplicationDetailsInfo.java | 4 +-
.../flink/runtime/minicluster/MiniCluster.java | 12 +-
.../util/ArchivedApplicationStoreUtils.java | 44 +++
.../application/AbstractApplicationTest.java | 31 ++
.../dispatcher/ArchivedApplicationStoreITCase.java | 114 ++++++
...java => ArchivedApplicationStoreTestUtils.java} | 126 ++++++-
.../FileArchivedApplicationStoreTest.java | 213 +++++++++++
.../FileExecutionGraphInfoStoreTest.java | 391 ---------------------
.../MemoryArchivedApplicationStoreTest.java | 294 ++++++++++++++++
.../MemoryExecutionGraphInfoStoreITCase.java | 68 ----
.../MemoryExecutionGraphInfoStoreTest.java | 270 --------------
.../runtime/dispatcher/TestingDispatcher.java | 15 +-
.../TestingPartialDispatcherServices.java | 16 +-
.../ZooKeeperDefaultDispatcherRunnerTest.java | 4 +-
.../runtime/entrypoint/ClusterEntrypointTest.java | 8 +-
.../ClusterUncaughtExceptionHandlerITCase.java | 4 +-
.../runtime/minicluster/TestingMiniCluster.java | 4 +-
.../application/ApplicationDetailsHandlerTest.java | 2 +-
.../ApplicationsOverviewHandlerTest.java | 2 +-
.../testutils/TestingClusterEntrypointProcess.java | 8 +-
.../recovery/ProcessFailureCancelingITCase.java | 4 +-
41 files changed, 1773 insertions(+), 1378 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{messages/FlinkApplicationNotFoundException.java
=> application/ApplicationStatusListener.java} (62%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/{ExecutionGraphInfoStore.java
=> ArchivedApplicationStore.java} (52%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/FileArchivedApplicationStore.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStore.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/{MemoryExecutionGraphInfoStore.java
=> MemoryArchivedApplicationStore.java} (55%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/util/ArchivedApplicationStoreUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/ArchivedApplicationStoreITCase.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/{ExecutionGraphInfoStoreTestUtils.java
=> ArchivedApplicationStoreTestUtils.java} (66%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/FileArchivedApplicationStoreTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/FileExecutionGraphInfoStoreTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MemoryArchivedApplicationStoreTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MemoryExecutionGraphInfoStoreITCase.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MemoryExecutionGraphInfoStoreTest.java
