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 9c9916e [FLINK-11589] Regenerate security configuration docs
add fa22ed2 [FLINK-14231][task] Add the quiesce() method to
ProcessingTimeService and remove TimerService::awaitPendingAfterQuiesce method
add ab642cb [FLINK-14231][runtime] Introduce and use
ProcessingTimeServiceAware to pass ProcessingTimeService to operator
add 56ce696 [FLINK-14231][task] Add StreamOperatorWrapper that handles
the close, endInput and other related logic of an operator
add 5fce538 [FLINK-14231][task] Change StreamTask to close operators with
StreamOperatorWrapper to make the endInput semantics on the chain strict
add fd1ee49 [hotfix][test] Clean up the codes in StreamTaskTestHarness,
StreamTaskTimerTest and TestProcessingTimeServiceTest
No new revisions were added by this update.
Summary of changes:
.../hdfstests/ContinuousFileProcessingTest.java | 1 -
.../java/org/apache/flink/hdfstests/Utils.java | 53 ++++
.../flink/state/api/output/BoundedStreamTask.java | 8 +-
.../runtime/NeverFireProcessingTimeService.java | 9 +-
.../source/ContinuousFileReaderOperator.java | 8 +-
.../ContinuousFileReaderOperatorFactory.java | 18 +-
.../api/operators/AbstractStreamOperator.java | 15 +-
.../operators/AbstractStreamOperatorFactory.java | 48 ++++
.../api/operators/SimpleOperatorFactory.java | 12 +-
.../api/operators/StreamOperatorFactoryUtil.java | 25 +-
.../api/operators/async/AsyncWaitOperator.java | 19 +-
.../operators/async/AsyncWaitOperatorFactory.java | 18 +-
.../streaming/runtime/tasks/OperatorChain.java | 175 +++++++-----
.../runtime/tasks/ProcessingTimeService.java | 13 +
.../runtime/tasks/ProcessingTimeServiceAware.java | 25 +-
...tory.java => ProcessingTimeServiceFactory.java} | 17 +-
.../runtime/tasks/ProcessingTimeServiceImpl.java | 74 ++++-
.../runtime/tasks/ProcessingTimeServiceUtil.java | 44 +++
.../runtime/tasks/StreamOperatorWrapper.java | 222 +++++++++++++++
.../flink/streaming/runtime/tasks/StreamTask.java | 108 +++-----
.../runtime/tasks/SystemProcessingTimeService.java | 43 +--
.../runtime/tasks/TestProcessingTimeService.java | 9 +-
.../streaming/runtime/tasks/TimerService.java | 17 --
.../api/operators/async/AsyncWaitOperatorTest.java | 5 +
.../runtime/operators/MailboxOperatorTest.java | 69 +++--
.../operators/StreamOperatorChainingTest.java | 13 +-
.../StreamSourceOperatorLatencyMetricsTest.java | 1 +
.../operators/StreamTaskOperatorTimerTest.java | 11 +-
.../runtime/operators/StreamTaskTimerTest.java | 12 +-
.../operators/TestProcessingTimeServiceTest.java | 20 +-
.../runtime/tasks/OneInputStreamTaskTest.java | 22 +-
.../streaming/runtime/tasks/OperatorChainTest.java | 31 ++-
.../tasks/ProcessingTimeServiceImplTest.java | 125 +++++++++
.../runtime/tasks/SourceStreamTaskTest.java | 53 ++--
.../runtime/tasks/StreamOperatorWrapperTest.java | 301 +++++++++++++++++++++
.../streaming/runtime/tasks/StreamTaskTest.java | 48 ++--
.../runtime/tasks/StreamTaskTestHarness.java | 34 +--
.../tasks/SystemProcessingTimeServiceTest.java | 6 +-
.../tasks/TestBoundedOneInputStreamOperator.java | 11 +-
.../tasks}/TestBoundedTwoInputOperator.java | 11 +-
.../runtime/tasks/TwoInputStreamTaskTest.java | 31 ++-
...AbstractBroadcastStreamOperatorTestHarness.java | 12 +-
.../util/AbstractStreamOperatorTestHarness.java | 19 +-
.../util/BroadcastOperatorTestHarness.java | 12 +-
.../util/KeyedBroadcastOperatorTestHarness.java | 13 +-
.../flink/streaming/util/MockStreamTask.java | 5 +-
.../util/MockStreamingRuntimeContext.java | 2 +-
.../util/OneInputStreamOperatorTestHarness.java | 11 +
.../planner/codegen/OperatorCodeGenerator.scala | 18 +-
.../runtime/operators/CodeGenOperatorFactory.java | 18 +-
.../runtime/operators/window/WindowOperator.java | 7 +-
.../wmassigners/WatermarkAssignerOperator.java | 12 +-
.../WatermarkAssignerOperatorFactory.java | 24 +-
.../operators/join/AsyncLookupJoinHarnessTest.java | 5 +-
.../wmassigners/WatermarkAssignerOperatorTest.java | 35 ++-
55 files changed, 1479 insertions(+), 499 deletions(-)
create mode 100644
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/Utils.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorFactory.java
copy
flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/RestClientFactory.java
=>
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceAware.java
(57%)
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/{mailbox/MailboxExecutorFactory.java
=> ProcessingTimeServiceFactory.java} (63%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceUtil.java
create mode 100755
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamOperatorWrapper.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceImplTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamOperatorWrapperTest.java
rename flink-streaming-java/src/test/java/org/apache/flink/streaming/{util =>
runtime/tasks}/TestBoundedTwoInputOperator.java (83%)
