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/25 07:50:17 UTC

[flink] branch master updated (327b024 -> 476e5af)

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 327b024  [FLINK-19304][coordination] Add FLIP-138 feature toggle
     add 476e5af  [FLINK-19288] Make the InternalTimeServiceManager an interface

No new revisions were added by this update.

Summary of changes:
 .../api/input/operator/StateReaderOperator.java    |   8 +-
 .../api/operators/AbstractStreamOperator.java      |  18 +-
 .../api/operators/AbstractStreamOperatorV2.java    |  20 +-
 .../api/operators/InternalTimeServiceManager.java  | 237 ++++-----------------
 ...er.java => InternalTimeServiceManagerImpl.java} |  93 +++++---
 .../InternalTimerServiceSerializationProxy.java    |   6 +-
 .../operators/StreamTaskStateInitializerImpl.java  |  52 ++---
 ...ava => InternalTimeServiceManagerImplTest.java} |  10 +-
 .../StateInitializationContextImplTest.java        |  32 +--
 .../StreamTaskStateInitializerImplTest.java        |  23 +-
 .../util/AbstractStreamOperatorTestHarness.java    |  37 +++-
 .../restore/StreamOperatorSnapshotRestoreTest.java |  26 ++-
 12 files changed, 223 insertions(+), 339 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/{InternalTimeServiceManager.java => InternalTimeServiceManagerImpl.java} (74%)
 rename flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/{InternalTimeServiceManagerTest.java => InternalTimeServiceManagerImplTest.java} (83%)