You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ch...@apache.org on 2019/11/15 12:22:00 UTC

[flink] branch master updated (749086d -> cc02399)

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 749086d  [FLINK-14794][runtime] Fixing KeyedStream#transform to properly relay type information if invoked with factories.
     add 6ae01fb  [hotfix][tests] Introduce PartitionDescriptorBuilder
     add cc02399  [FLINK-14679][shuffle] Store number of partitions in PartitionDescriptor

No new revisions were added by this update.

Summary of changes:
 .../ResultPartitionDeploymentDescriptor.java       |  4 ++
 .../flink/runtime/shuffle/PartitionDescriptor.java | 11 ++++
 .../ResultPartitionDeploymentDescriptorTest.java   |  3 ++
 .../runtime/deployment/ShuffleDescriptorTest.java  | 12 ++---
 .../partition/AbstractPartitionTrackerTest.java    | 14 +++--
 .../io/network/partition/PartitionTestUtils.java   | 13 +++--
 .../partition/ResultPartitionFactoryTest.java      | 14 ++---
 .../shuffle/PartitionDescriptorBuilder.java        | 60 ++++++++++++++++++++++
 .../taskexecutor/TaskExecutorSubmissionTest.java   | 11 ++--
 .../apache/flink/runtime/taskmanager/TaskTest.java |  9 +---
 10 files changed, 107 insertions(+), 44 deletions(-)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/shuffle/PartitionDescriptorBuilder.java