[flink] branch master updated (27307b4 -> 8543334)

[zh...@apache.org]

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