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

Posted to commits@flink.apache.org by ga...@apache.org on 2019/11/20 16:13:08 UTC

[flink] branch master updated (53060f8 -> 3261292)

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

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


    from 53060f8  [FLINK-14433][DataStream] Move generated Jaas conf file from /tmp directory to Job specific directory
     add f87bc82  [FLINK-14362][runtime] Fix DefaultResultPartition to return true result partition state
     add 3261292  [hotfix][runtime] Log errors that happen in DefaultScheduler deployment

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/scheduler/DefaultScheduler.java  | 11 +++--
 .../adapter/DefaultExecutionTopology.java          | 22 ++-------
 .../scheduler/adapter/DefaultResultPartition.java  | 20 ++++----
 .../strategy/InputDependencyConstraintChecker.java |  6 +--
 ...ategyFactory.java => ResultPartitionState.java} | 21 +++++----
 .../strategy/SchedulingResultPartition.java        | 25 ----------
 .../adapter/DefaultExecutionTopologyTest.java      | 22 ++++++++-
 .../adapter/DefaultExecutionVertexTest.java        |  6 ++-
 .../adapter/DefaultResultPartitionTest.java        | 53 ++++++----------------
 .../InputDependencyConstraintCheckerTest.java      | 15 +++---
 .../LazyFromSourcesSchedulingStrategyTest.java     | 14 +++---
 .../strategy/TestingSchedulingResultPartition.java |  2 +-
 .../strategy/TestingSchedulingTopology.java        |  6 +--
 13 files changed, 87 insertions(+), 136 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/{SchedulingStrategyFactory.java => ResultPartitionState.java} (69%)