You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/10/24 08:57:31 UTC
[flink] branch master updated (76cd40e -> 432efb3)
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 76cd40e [FLINK-13873][rocksdb][metrics] Optionally expose column_family as variable
add c83f724 [hotfix][runtime] Refactoring: remove ProcessingTimeService::shutdownAndAwaitPending method
add 8665c38 [hotfix][runtime] Refactoring: move timer service lifecycle methods into a separate interface
add 9ca6e15 [hotfix][tests] Reformat StreamSourceOperatorWatermarksTest according to code style (method argument on new lines)
add 92eb7b1 [FLINK-14156][runtime] Refactoring: move ProcessingTimeService access request at operator level
add e4c0042 [FLINK-14156][runtime] Instantiate ProcessingTimeService per operator (with timer execution by operator precedence)
add b93e220 [hotfix][tests] RocksDBAsyncSnapshotTest: use test harness helper method to wait until task is running
add 432efb3 [FLINK-14156][tests] Rewrite StreamTaskOperatorTimerTest to observe flow via output (to avoid using mutable static fields)
No new revisions were added by this update.
Summary of changes:
.../state/api/input/KeyedStateInputFormat.java | 4 +-
.../runtime/NeverFireProcessingTimeService.java | 12 +-
.../streaming/state/RocksDBAsyncSnapshotTest.java | 24 +--
.../api/operators/AbstractStreamOperator.java | 7 +-
.../api/operators/InternalTimerServiceImpl.java | 12 +-
.../api/operators/StreamTaskStateInitializer.java | 3 +
.../operators/StreamTaskStateInitializerImpl.java | 11 +-
.../runtime/tasks/OneInputStreamTask.java | 4 +-
.../runtime/tasks/ProcessingTimeService.java | 71 +--------
.../runtime/tasks/ProcessingTimeServiceImpl.java | 49 ++++++
.../flink/streaming/runtime/tasks/StreamTask.java | 80 +++++-----
.../runtime/tasks/SystemProcessingTimeService.java | 50 ++++---
.../runtime/tasks/TestProcessingTimeService.java | 12 +-
...rocessingTimeService.java => TimerService.java} | 59 ++------
.../StateInitializationContextImplTest.java | 5 +-
.../StreamTaskStateInitializerImplTest.java | 11 +-
.../StreamSourceOperatorLatencyMetricsTest.java | 6 +-
.../StreamSourceOperatorWatermarksTest.java | 21 +--
.../operators/StreamTaskOperatorTimerTest.java | 164 +++++++++++++++++++++
.../runtime/operators/StreamTaskTimerTest.java | 2 +-
.../operators/TestProcessingTimeServiceTest.java | 13 +-
.../runtime/tasks/OneInputStreamTaskTest.java | 4 +-
.../streaming/runtime/tasks/OperatorChainTest.java | 4 +-
.../runtime/tasks/StreamConfigChainer.java | 26 ++--
.../streaming/runtime/tasks/StreamTaskTest.java | 14 +-
.../runtime/tasks/StreamTaskTestHarness.java | 14 +-
.../tasks/SystemProcessingTimeServiceTest.java | 44 +-----
.../util/AbstractStreamOperatorTestHarness.java | 10 +-
.../flink/streaming/util/MockStreamTask.java | 24 +--
.../streaming/util/MockStreamTaskBuilder.java | 12 +-
.../restore/StreamOperatorSnapshotRestoreTest.java | 3 +-
31 files changed, 411 insertions(+), 364 deletions(-)
create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceImpl.java
copy flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/{ProcessingTimeService.java => TimerService.java} (56%)
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/StreamTaskOperatorTimerTest.java