This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4513b59 [hotfix][docs] Use non deprecated syntax in SinkFunction code
sample
add b3fc853 [hotfix][state/changelog] Change OpertorID type to string
add cd6b052 [hotfix][state/changelog] Check delegated state for not being
changelog
add fb3b7f7 [FLINK-21355][state/changelog] Log changes (no metadata)
No new revisions were added by this update.
Summary of changes:
.../runtime/state/AbstractKeyedStateBackend.java | 4 +
.../changelog/StateChangelogWriterFactory.java | 3 +-
.../InMemoryStateChangelogWriterFactory.java | 3 +-
.../flink/runtime/state/StateBackendTestBase.java | 8 +-
.../inmemory/StateChangelogWriterFactoryTest.java | 5 +-
.../state/changelog/AbstractChangelogState.java | 17 +-
.../state/changelog/AbstractStateChangeLogger.java | 181 +++++++++++++++
.../state/changelog/ChangelogAggregatingState.java | 27 ++-
.../ChangelogKeyGroupedPriorityQueue.java | 62 ++++-
.../changelog/ChangelogKeyedStateBackend.java | 33 ++-
.../flink/state/changelog/ChangelogListState.java | 37 ++-
.../flink/state/changelog/ChangelogMapState.java | 128 ++++++++++-
.../state/changelog/ChangelogReducingState.java | 30 ++-
.../state/changelog/ChangelogStateBackend.java | 18 +-
.../flink/state/changelog/ChangelogValueState.java | 17 +-
.../flink/state/changelog/KvStateChangeLogger.java | 24 +-
.../state/changelog/KvStateChangeLoggerImpl.java | 77 +++++++
.../changelog/PriorityQueueStateChangeLogger.java | 16 +-
.../PriorityQueueStateChangeLoggerImpl.java | 54 +++++
.../flink/state/changelog/StateChangeLogger.java | 72 ++++++
.../changelog/StateChangeLoggingIterator.java | 80 +++++++
.../state/changelog/ChangelogListStateTest.java | 209 +++++++++++++++++
.../state/changelog/ChangelogMapStateTest.java | 253 +++++++++++++++++++++
.../state/changelog/ChangelogPqStateTest.java | 233 +++++++++++++++++++
.../flink/state/changelog/TestChangeLoggerKv.java | 134 +++++++++++
25 files changed, 1650 insertions(+), 75 deletions(-)
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractStateChangeLogger.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/inmemory/InMemoryStateChangelogWriterFactory.java
=>
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/KvStateChangeLogger.java
(55%)
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/KvStateChangeLoggerImpl.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/inmemory/InMemoryStateChangelogWriterFactory.java
=>
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PriorityQueueStateChangeLogger.java
(55%)
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PriorityQueueStateChangeLoggerImpl.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/StateChangeLogger.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/StateChangeLoggingIterator.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogListStateTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogMapStateTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogPqStateTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/TestChangeLoggerKv.java
