You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2022/01/19 15:30:52 UTC
[flink] branch master updated (50ff508 -> 95f3f7d)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 50ff508 [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore
add d0c8606 [hotfix] Replace hamcrest with assertJ in ConfigurationUtilsTest
add 6bbf57f [hotfix] Rename ClusterEntrypoint.ShutdownBehaviour enum values
add f1077100 [FLINK-25402] Make JobManager process resource id configurable via jobmanager.resource-id
add 09deea1 [FLINK-25402] Introduce ClusterOptions.PROCESS_WORKING_DIR_BASE for configuring a process directory
add 856e511 [FLINK-25402] Clear tmp directory when setting up the working directory
add 26da686 [FLINK-25402] Let taskmanager.state.local.root-dirs default to <WORKING_DIR>/localState
add 617635d [FLINK-25402] Set state.backend.rocksdb.localdir to default to <WORKING_DIR>/tmp
add 95f3f7d [hotfix] Remove unused TaskExecutorLocalStateStoresManagerTest.TOTAL_FLINK_MEMORY_MB
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 6 ++
.../generated/checkpointing_configuration.html | 2 +-
.../generated/cluster_configuration.html | 18 ++++
.../generated/common_state_backends_section.html | 2 +-
.../generated/expert_cluster_section.html | 18 ++++
.../generated/expert_rocksdb_section.html | 2 +-
.../generated/job_manager_configuration.html | 6 ++
.../generated/rocksdb_configuration.html | 2 +-
.../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 6 +-
.../application/ApplicationClusterEntryPoint.java | 4 +-
.../flink/configuration/CheckpointingOptions.java | 15 ++-
.../apache/flink/configuration/ClusterOptions.java | 42 ++++++++
.../flink/configuration/ConfigurationUtils.java | 23 +++++
.../flink/configuration/JobManagerOptions.java | 11 +++
.../configuration/ConfigurationUtilsTest.java | 45 +++++++--
.../org/apache/flink/testutils/TestFileUtils.java | 7 ++
.../state/api/runtime/SavepointEnvironment.java | 2 +-
.../runtime/SavepointTaskManagerRuntimeInfo.java | 17 +++-
.../runtime/entrypoint/ClusterEntrypoint.java | 76 ++++++++++++---
.../runtime/entrypoint/ClusterEntrypointUtils.java | 106 +++++++++++++++++++++
.../flink/runtime/entrypoint/WorkingDirectory.java | 83 ++++++++++++++++
...tDispatcherResourceManagerComponentFactory.java | 3 +
.../DispatcherResourceManagerComponentFactory.java | 2 +
.../flink/runtime/minicluster/MiniCluster.java | 27 +++++-
.../resourcemanager/ResourceManagerFactory.java | 7 +-
.../ResourceManagerProcessContext.java | 8 ++
.../ResourceManagerServiceImpl.java | 5 +-
.../taskexecutor/TaskManagerConfiguration.java | 13 ++-
.../runtime/taskexecutor/TaskManagerRunner.java | 41 +++++++-
.../TaskManagerServicesConfiguration.java | 16 +++-
.../taskmanager/TaskManagerRuntimeInfo.java | 9 ++
.../FileExecutionGraphInfoStoreTest.java | 2 +
.../runtime/entrypoint/ClusterEntrypointTest.java | 79 +++++++++++++++
.../runtime/entrypoint/WorkingDirectoryTest.java | 54 +++++++++++
.../runtime/minicluster/TestingMiniCluster.java | 2 +
.../ResourceManagerServiceImplTest.java | 2 +
.../TestingResourceManagerService.java | 2 +
.../TaskExecutorLocalStateStoresManagerTest.java | 25 +++--
.../StartStopNotifyingLeaderRetrievalService.java} | 37 ++++---
...cutorExecutionDeploymentReconciliationTest.java | 4 +-
.../TaskExecutorPartitionLifecycleTest.java | 4 +-
.../taskexecutor/TaskExecutorSlotLifetimeTest.java | 4 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 52 ++++------
.../taskexecutor/TaskManagerRunnerStartupTest.java | 36 ++++++-
.../taskexecutor/TaskManagerRunnerTest.java | 99 +++++++++++++++++++
.../TaskSubmissionTestEnvironment.java | 8 +-
.../WorkingDirectoryExtension.java} | 26 ++---
.../testutils/WorkingDirectoryResource.java | 33 +++----
.../runtime/util/JvmExitOnFatalErrorTest.java | 25 +++--
.../util/TestingTaskManagerRuntimeInfo.java | 27 +++++-
.../state/EmbeddedRocksDBStateBackend.java | 5 +-
.../contrib/streaming/state/RocksDBOptions.java | 12 ++-
.../state/RocksDBStateBackendConfigTest.java | 22 +----
...tractTaskManagerProcessFailureRecoveryTest.java | 2 +-
.../test/recovery/ClusterEntrypointITCase.java | 84 ++++++++++++++++
.../recovery/ProcessFailureCancelingITCase.java | 2 +
.../test/recovery/TaskManagerRunnerITCase.java | 90 +++++++++++++++++
57 files changed, 1173 insertions(+), 189 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/WorkingDirectory.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/WorkingDirectoryTest.java
copy flink-runtime/src/{main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorToServiceAdapter.java => test/java/org/apache/flink/runtime/taskexecutor/StartStopNotifyingLeaderRetrievalService.java} (52%)
copy flink-runtime/src/test/java/org/apache/flink/runtime/{blob/VoidPermanentBlobService.java => testutils/WorkingDirectoryExtension.java} (57%)
copy flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/LegacyRowResource.java => flink-runtime/src/test/java/org/apache/flink/runtime/testutils/WorkingDirectoryResource.java (55%)
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/recovery/ClusterEntrypointITCase.java
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerRunnerITCase.java