This is an automated email from the ASF dual-hosted git repository.
zhijiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 27307b4 [FLINK-14415][table-common] ValueLiteralExpression#equals
should take array value into account (#9915)
add ecc8020 [FLINK-14230][task] Change the endInput call of the
downstream operator to after the upstream operator closes
add d4be257 [FLINK-14230][datastream] Remove the BoundedOneInput
implementation of AsyncWaitOperator and ContinuousFileReaderOperator
add 8543334 [hotfix][test] Clean up the test code in SourceStreamTaskTest
and OneInputStreamTaskTest
No new revisions were added by this update.
Summary of changes:
.../source/ContinuousFileReaderOperator.java | 8 +-
.../streaming/api/operators/StreamSource.java | 4 +-
.../api/operators/async/AsyncWaitOperator.java | 8 +-
.../runtime/io/StreamOneInputProcessor.java | 2 +-
.../runtime/io/StreamTwoInputProcessor.java | 2 +-
.../streaming/runtime/tasks/OperatorChain.java | 62 +++++---------
.../flink/streaming/runtime/tasks/StreamTask.java | 7 ++
.../api/operators/async/AsyncWaitOperatorTest.java | 62 --------------
.../runtime/tasks/OneInputStreamTaskTest.java | 81 +++++++++---------
.../runtime/tasks/SourceStreamTaskTest.java | 38 +++++++--
.../tasks/TestBoundedOneInputStreamOperator.java | 6 ++
.../runtime/tasks/TwoInputStreamTaskTest.java | 6 +-
.../util/OneInputStreamOperatorTestHarness.java | 9 --
.../util/TestBoundedTwoInputOperator.java | 8 +-
.../api/ContinuousFileReaderOperatorITCase.java | 98 ----------------------
15 files changed, 125 insertions(+), 276 deletions(-)
delete mode 100644
flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousFileReaderOperatorITCase.java
