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 40cbf231e3d [FLINK-33973] Add new interfaces for SinkV2 to synchronize
the API with the SourceV2 API
add 8a205367fbf [hotfix] Migrate
StreamExecutionEnvironmentComplexConfigurationTest to Junit5 and AssertJ
add 06b37089f0c [FLINK-33980][core] Extend ReadableConfig with toMap
method.
add 290b633c426 [FLINK-33980][core] Migrate configuration in
StreamExecutionEnvironment, ExecutionConfig and CheckpointConfig.
add 65b8b3baad6 [FLINK-33980][core] Pass job configuration to jobGraph.
add d02ef1cebf3 [FLINK-33980][core] Support generate
RestartBackoffTimeStrategyFactory from job configuration.
add eb8af0c589c [FLINK-33980][core] Support generate StateBackend and
CheckpointStorage from job configuration.
No new revisions were added by this update.
Summary of changes:
.../client/program/StreamContextEnvironment.java | 28 +--
.../program/StreamContextEnvironmentTest.java | 3 -
.../apache/flink/api/common/ExecutionConfig.java | 36 +++-
.../flink/api/common/cache/DistributedCache.java | 18 +-
.../flink/configuration/ConfigurationUtils.java | 6 +-
.../apache/flink/configuration/ReadableConfig.java | 11 ++
.../configuration/RestartStrategyOptions.java | 41 +++--
.../StateChangelogOptionsInternal.java | 37 ----
.../flink/api/common/ExecutionConfigTest.java | 29 +--
.../api/input/StreamOperatorContextBuilder.java | 9 +-
.../state/api/runtime/SavepointEnvironment.java | 7 +-
.../flink/state/api/SavepointWriterTest.java | 11 +-
.../tests/test_stream_execution_environment.py | 3 +-
flink-python/pyflink/table/table_config.py | 7 +
.../java/org/apache/flink/python/PythonConfig.java | 9 +
.../process/ExternalPythonCoProcessOperator.java | 1 +
.../ExternalPythonKeyedCoProcessOperator.java | 1 +
.../ExternalPythonKeyedProcessOperator.java | 1 +
.../process/ExternalPythonProcessOperator.java | 1 +
.../python/AbstractStatelessFunctionOperator.java | 1 +
.../AbstractPythonStreamAggregateOperator.java | 1 +
.../flink/runtime/checkpoint/Checkpoints.java | 24 ++-
.../DefaultExecutionGraphBuilder.java | 4 +-
.../RestartBackoffTimeStrategyFactoryLoader.java | 71 ++++----
.../apache/flink/runtime/jobgraph/JobGraph.java | 18 +-
.../runtime/scheduler/DefaultSchedulerFactory.java | 1 +
.../adaptive/AdaptiveSchedulerFactory.java | 1 +
.../AdaptiveBatchSchedulerFactory.java | 1 +
.../runtime/state/CheckpointStorageLoader.java | 36 ++--
.../flink/runtime/state/StateBackendLoader.java | 42 +++--
.../state/TaskExecutorLocalStateStoresManager.java | 5 +-
.../util/config/memory/ManagedMemoryUtils.java | 7 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 5 +-
...estartBackoffTimeStrategyFactoryLoaderTest.java | 114 ++++++++++--
.../runtime/state/CheckpointStorageLoaderTest.java | 131 +++++++++-----
.../runtime/state/StateBackendLoadingTest.java | 75 +++++---
.../util/config/memory/ManagedMemoryUtilsTest.java | 5 +
.../ChangelogStateBackendLoadingTest.java | 34 ++--
.../state/RocksDBStateBackendFactoryTest.java | 3 +-
.../api/environment/CheckpointConfig.java | 14 ++
.../environment/StreamExecutionEnvironment.java | 195 ++++++---------------
.../flink/streaming/api/graph/StreamConfig.java | 17 +-
.../flink/streaming/api/graph/StreamGraph.java | 59 ++-----
.../streaming/api/graph/StreamGraphGenerator.java | 80 ++-------
.../api/graph/StreamingJobGraphGenerator.java | 12 +-
.../api/operators/AbstractStreamOperator.java | 1 +
.../api/operators/AbstractStreamOperatorV2.java | 1 +
.../api/operators/StreamingRuntimeContext.java | 5 +
.../io/StreamMultipleInputProcessorFactory.java | 1 +
.../runtime/io/StreamTwoInputProcessorFactory.java | 1 +
.../runtime/tasks/OneInputStreamTask.java | 1 +
.../flink/streaming/runtime/tasks/StreamTask.java | 18 +-
...ecutionEnvironmentComplexConfigurationTest.java | 124 +++++++------
.../StreamExecutionEnvironmentTest.java | 26 +--
.../api/graph/StreamingJobGraphGeneratorTest.java | 4 +
.../org/apache/flink/table/api/TableConfig.java | 9 +
.../planner/plan/nodes/exec/ExecNodeConfig.java | 10 ++
.../runtime/operators/TableStreamOperator.java | 1 +
.../window/LocalSlicingWindowAggOperator.java | 1 +
.../operators/fusion/FusionStreamOperatorBase.java | 1 +
.../BatchMultipleInputStreamOperator.java | 1 +
.../over/BufferDataOverWindowOperatorTest.java | 1 +
.../CheckpointAfterAllTasksFinishedITCase.java | 10 +-
.../checkpointing/RestoreUpgradedJobITCase.java | 1 +
.../distributedcache/DistributedCacheTest.java | 31 ++++
65 files changed, 793 insertions(+), 670 deletions(-)
delete mode 100644
flink-core/src/main/java/org/apache/flink/configuration/StateChangelogOptionsInternal.java
