This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7b9aac3d [FLINK-22889] Add debug statements to
JdbcExactlyOnceSinkE2eTest
add e1ea4d9 [FLINK-21804][state/changelog] Create and wire changelog
storage with state backend
No new revisions were added by this update.
Summary of changes:
.../generated/checkpointing_configuration.html | 6 +
.../generated/common_state_backends_section.html | 6 +
.../flink/configuration/CheckpointingOptions.java | 24 +++
.../api/runtime/SavepointTaskStateManager.java | 7 +
.../TaskExecutorStateChangelogStoragesManager.java | 147 +++++++++++++++
.../flink/runtime/state/TaskStateManager.java | 5 +
.../flink/runtime/state/TaskStateManagerImpl.java | 14 ++
.../state/changelog/StateChangelogStorage.java | 5 +-
.../changelog/StateChangelogStorageFactory.java | 20 +--
.../changelog/StateChangelogStorageLoader.java | 72 +++++++-
...a => InMemoryStateChangelogStorageFactory.java} | 21 ++-
.../flink/runtime/taskexecutor/TaskExecutor.java | 15 ++
.../runtime/taskexecutor/TaskManagerRunner.java | 3 +
.../runtime/taskexecutor/TaskManagerServices.java | 12 ++
...e.state.changelog.StateChangelogStorageFactory} | 2 +-
...kExecutorStateChangelogStoragesManagerTest.java | 197 +++++++++++++++++++++
.../runtime/state/TaskStateManagerImplTest.java | 18 +-
.../flink/runtime/state/TestTaskStateManager.java | 8 +
.../inmemory/StateChangelogStorageLoaderTest.java | 69 ++++++--
.../taskexecutor/TaskManagerServicesBuilder.java | 10 ++
.../runtime/util/JvmExitOnFatalErrorTest.java | 6 +
.../state/changelog/ChangelogStateBackend.java | 9 +-
.../StateInitializationContextImplTest.java | 2 +
.../StreamTaskStateInitializerImplTest.java | 5 +-
.../runtime/tasks/LocalStateForwardingTest.java | 11 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 3 +
26 files changed, 644 insertions(+), 53 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManager.java
copy
flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerFactory.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogStorageFactory.java
(65%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/inmemory/{InMemoryStateChangelogStorage.java
=> InMemoryStateChangelogStorageFactory.java} (57%)
rename
flink-runtime/src/main/resources/META-INF/services/{org.apache.flink.runtime.state.changelog.StateChangelogStorage
=> org.apache.flink.runtime.state.changelog.StateChangelogStorageFactory} (97%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/state/TaskExecutorStateChangelogStoragesManagerTest.java
