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/04/09 07:04:16 UTC

[flink] branch master updated (4e51682 -> 0d21f47)

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

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


    from 4e51682  [FLINK-16696][javadocs] Correct field name for operation result
     add 841205c  [FLINK-17047][runtime] Change SchedulingStrategy#onPartitionConsumable(…) to take IntermediateResultPartitionID instead of ResultPartitionID
     add 0d21f47  [FLINK-17047][runtime] Remove the producerId param from SchedulingStrategy#onPartitionConsumable(…)

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/runtime/scheduler/DefaultScheduler.java   |  6 +++---
 .../org/apache/flink/runtime/scheduler/SchedulerBase.java  |  6 +++---
 .../scheduler/strategy/EagerSchedulingStrategy.java        |  4 ++--
 .../strategy/LazyFromSourcesSchedulingStrategy.java        | 14 +++-----------
 .../runtime/scheduler/strategy/SchedulingStrategy.java     |  5 ++---
 .../strategy/LazyFromSourcesSchedulingStrategyTest.java    |  4 +---
 .../runtime/scheduler/strategy/TestSchedulingStrategy.java |  4 ++--
 7 files changed, 16 insertions(+), 27 deletions(-)