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 2020/05/12 17:57:09 UTC

[flink] branch master updated (84574fb -> 71e85d8)

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 84574fb  [FLINK-17640][network] Temporarily disable unstable RecoveredInputChannelTest#testConcurrentReadStateAndProcessAndRelease
     add 755b576  [FLINK-17315][checkpointing] Fix NPE in unaligned checkpoint after EndOfPartition events
     add 8ebba92  [FLINK-17315][checkpointing] Disable priority event listener
     add 1eda834  [FLINK-17315][checkpointing] LocalInputChannel also checkpoints in-flight data.
     add 0d08d23  [FLINK-17315][checkpointing] Fixed SpillingAdaptiveSpanningRecordDeserializer#getUnconsumedBuffer.
     add 1e20d61  [FLINK-17315][checkpointing] Only adding buffers to inflight data of PipelinedSubpartition.
     add 71e85d8  [FLINK-17315][tests] Fix and reenable UnalignedCheckpointITCase.

No new revisions were added by this update.

Summary of changes:
 ...SpillingAdaptiveSpanningRecordDeserializer.java |  2 +
 .../network/partition/PipelinedSubpartition.java   |  9 ++--
 .../partition/consumer/LocalInputChannel.java      | 24 ++++++++++-
 .../runtime/jobgraph/tasks/AbstractInvokable.java  |  3 +-
 .../SpanningRecordSerializationTest.java           |  9 ++++
 .../PipelinedSubpartitionWithReadViewTest.java     | 50 ++++++----------------
 .../partition/consumer/LocalInputChannelTest.java  | 43 +++++++++++++++++++
 .../operators/testutils/DummyInvokable.java        | 13 ++++--
 .../runtime/io/StreamTaskNetworkInput.java         | 15 ++++---
 .../runtime/io/StreamTaskNetworkInputTest.java     | 47 ++++++++++++++++++++
 .../checkpointing/UnalignedCheckpointITCase.java   | 13 +++---
 11 files changed, 167 insertions(+), 61 deletions(-)