You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by dw...@apache.org on 2020/09/22 16:06:08 UTC

[flink] branch master updated (9258fcb -> 23a4107)

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 9258fcb  [FLINK-19140][docs] Fix UDTF documentation which uses wrong alias
     add 23a4107  [FLINK-19270] Extract CheckpointableKeyedStateBackend interface

No new revisions were added by this update.

Summary of changes:
 .../flink/streaming/tests/StubStateBackend.java    |  4 +--
 .../runtime/state/AbstractKeyedStateBackend.java   |  8 +++---
 ...e.java => CheckpointableKeyedStateBackend.java} | 30 ++++++++++------------
 .../apache/flink/runtime/state/StateBackend.java   |  6 ++---
 .../HeapKeyedStateBackendAsyncByDefaultTest.java   |  7 +++--
 .../runtime/state/ttl/StateBackendTestContext.java |  6 ++---
 .../api/operators/InternalTimeServiceManager.java  | 23 ++++++-----------
 .../api/operators/StreamOperatorStateContext.java  |  4 +--
 .../api/operators/StreamOperatorStateHandler.java  | 30 +++++++++++-----------
 .../operators/StreamTaskStateInitializerImpl.java  | 19 ++++++++------
 .../StateInitializationContextImplTest.java        |  4 +--
 .../operators/StreamOperatorStateHandlerTest.java  |  9 +++++--
 .../StreamTaskStateInitializerImplTest.java        | 11 ++++----
 .../streaming/runtime/tasks/StreamTaskTest.java    |  3 ++-
 .../restore/StreamOperatorSnapshotRestoreTest.java | 13 +++++-----
 15 files changed, 90 insertions(+), 87 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/state/{KeyedStateHandle.java => CheckpointableKeyedStateBackend.java} (54%)