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 8319bf4 [FLINK-23223] Notifies if there are available data on
resumption for pipelined subpartition
add a3405df [hotfix][state/ttl] Don't wrap with TTL twice
add f2eb655 [FLINK-23277][state/changelog] Store and recover TTL metadata
using changelog
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/state/ttl/TtlStateFactory.java | 46 +++++++++++++++-------
.../apache/flink/runtime/state/ttl/TtlValue.java | 3 ++
.../state/changelog/AbstractStateChangeLogger.java | 17 +++++++-
.../changelog/ChangelogKeyedStateBackend.java | 32 +++++++++++----
.../state/changelog/KvStateChangeLoggerImpl.java | 6 ++-
.../PriorityQueueStateChangeLoggerImpl.java | 3 +-
.../restore/ChangelogBackendLogApplier.java | 34 ++++++++++++++--
.../changelog/KvStateChangeLoggerImplTest.java | 9 ++++-
8 files changed, 119 insertions(+), 31 deletions(-)
