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/18 05:24:59 UTC
[flink] branch master updated (6cf07d3 -> ddec073)

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 6cf07d3  [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY
     add 0a8eb8d  [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors
     add ddec073  [hotfix][task][tests] Remove useless import from TaskTest class

No new revisions were added by this update.

Summary of changes:
 .../deployment/TaskDeploymentDescriptor.java       | 14 ++++++-------
 .../io/network/NettyShuffleEnvironment.java        |  9 ++++++---
 .../ReleaseOnConsumptionResultPartition.java       |  2 ++
 .../io/network/partition/ResultPartition.java      | 10 ++++++++++
 .../network/partition/ResultPartitionFactory.java  |  5 +++++
 .../io/network/partition/ResultSubpartition.java   | 10 ++++++++++
 .../network/partition/consumer/InputChannel.java   | 11 +++++++++++
 .../partition/consumer/SingleInputGate.java        | 10 ++++++++++
 .../partition/consumer/SingleInputGateFactory.java |  2 ++
 .../flink/runtime/shuffle/ShuffleEnvironment.java  |  9 +++++----
 .../org/apache/flink/runtime/taskmanager/Task.java |  5 +++--
 .../TaskDeploymentDescriptorBuilder.java           | 10 +++++-----
 .../network/partition/InputGateFairnessTest.java   |  4 +++-
 .../network/partition/ResultPartitionBuilder.java  |  8 ++++++++
 .../partition/ResultPartitionFactoryTest.java      |  2 +-
 .../io/network/partition/ResultPartitionTest.java  | 22 +++++++++++++++++++++
 .../TaskExecutorPartitionTrackerImplTest.java      |  5 +++--
 .../partition/consumer/SingleInputGateBuilder.java |  8 ++++++++
 .../partition/consumer/SingleInputGateTest.java    | 23 ++++++++++++++++++++++
 .../taskexecutor/TaskExecutorSubmissionTest.java   |  9 +++++----
 .../apache/flink/runtime/taskmanager/TaskTest.java | 11 +++++------
 .../flink/runtime/taskmanager/TestTaskBuilder.java |  9 +++++----
 .../StreamNetworkBenchmarkEnvironment.java         |  5 +++--
 23 files changed, 162 insertions(+), 41 deletions(-)