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%)
