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/10/27 08:02:52 UTC

[flink] branch master updated (4e4b655 -> 698f962)

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 4e4b655  [FLINK-19412][python] Refactor Python operation to eliminate code duplication
     add 11f9837  [FLINK-19547][Runtime] Add the partialRecordLength when creating a BufferConsumer
     add 28d2766  [FLINK-19547][Runtime] Update `BufferConsumer` with `BufferConsumerWithPartialRecordLength` in PipelinedSubpartition.java
     add 698f962  [hotfix][runtime] Rename XXXSubPartitionBufferBuilderXXX to XXXUnicastBufferBuilderXXX

No new revisions were added by this update.

Summary of changes:
 .../channel/RecoveredChannelStateHandler.java      |   2 +-
 .../runtime/io/network/buffer/BufferBuilder.java   |  15 +-
 .../runtime/io/network/buffer/BufferConsumer.java  |  22 ++-
 .../BufferConsumerWithPartialRecordLength.java     |  95 +++++++++++++
 .../partition/BoundedBlockingSubpartition.java     |   2 +-
 .../partition/BufferWritingResultPartition.java    | 152 ++++++++++++++-------
 .../partition/CheckpointedResultSubpartition.java  |   2 +-
 .../network/partition/PipelinedSubpartition.java   |  49 ++++---
 .../io/network/partition/ResultSubpartition.java   |  10 +-
 .../BufferConsumerWithPartialRecordLengthTest.java | 149 ++++++++++++++++++++
 .../io/network/partition/ResultPartitionTest.java  |  38 ++++++
 11 files changed, 458 insertions(+), 78 deletions(-)
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLength.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferConsumerWithPartialRecordLengthTest.java