You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2020/03/25 06:09:06 UTC
[flink] branch master updated (d38a010 -> bb4ec22)

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 d38a010  [FLINK-15579][table-planner-blink] Fix UpsertStreamTableSink support and add tests
     add bb4ec22  [FLINK-16712][task] Refactor StreamTask to construct final fields

No new revisions were added by this update.

Summary of changes:
 .../flink/state/api/output/BoundedStreamTask.java  |  2 +-
 .../runtime/tasks/AbstractTwoInputStreamTask.java  |  2 +-
 .../runtime/tasks/MultipleInputStreamTask.java     |  2 +-
 .../runtime/tasks/OneInputStreamTask.java          |  4 +-
 .../runtime/tasks/SourceReaderStreamTask.java      |  2 +-
 .../streaming/runtime/tasks/SourceStreamTask.java  |  4 +-
 .../runtime/tasks/StreamIterationHead.java         |  2 +-
 .../runtime/tasks/StreamIterationTail.java         |  2 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  | 68 +++++++++-------------
 .../runtime/tasks/TwoInputStreamTask.java          |  2 +-
 .../runtime/tasks/LocalStateForwardingTest.java    |  2 +-
 .../MultipleInputStreamTaskTestHarnessBuilder.java |  4 +-
 .../tasks/OneInputStreamTaskTestHarness.java       | 10 ++--
 .../tasks/StreamTaskExecutionDecorationTest.java   |  2 +-
 .../tasks/StreamTaskMailboxTestHarnessBuilder.java |  6 +-
 .../tasks/StreamTaskSelectiveReadingTest.java      |  2 +-
 .../runtime/tasks/StreamTaskTerminationTest.java   |  2 +-
 .../streaming/runtime/tasks/StreamTaskTest.java    | 19 +++---
 .../runtime/tasks/StreamTaskTestHarness.java       | 18 +++---
 .../runtime/tasks/SynchronousCheckpointITCase.java |  2 +-
 .../runtime/tasks/SynchronousCheckpointTest.java   |  6 +-
 .../tasks/TaskCheckpointingBehaviourTest.java      |  2 +-
 .../tasks/TwoInputStreamTaskTestHarness.java       |  6 +-
 .../flink/streaming/util/MockStreamTask.java       |  2 +-
 .../streaming/util/MockStreamTaskBuilder.java      |  2 +-
 .../codegen/agg/batch/BatchAggTestBase.scala       |  5 +-
 .../jobmaster/JobMasterStopWithSavepointIT.java    |  6 +-
 27 files changed, 91 insertions(+), 95 deletions(-)