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

Posted to commits@flink.apache.org by dm...@apache.org on 2023/05/24 07:25:08 UTC

[flink] branch master updated (ae9e38ade27 -> 1cc81aa68ce)

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

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


    from ae9e38ade27 [FLINK-32056][Python][Connector/Pulsar] Add missing APIs in flink-connector-pulsar v4.0.0
     add 1cc81aa68ce [FLINK-31891][runtime] Introduce AdaptiveScheduler per-task failure enrichment/labeling

No new revisions were added by this update.

Summary of changes:
 .../scheduler/adaptive/AdaptiveScheduler.java      |  28 +-
 .../adaptive/AdaptiveSchedulerFactory.java         |   1 +
 .../adaptive/StateWithExecutionGraph.java          |  10 +-
 .../adaptive/AdaptiveSchedulerBuilder.java         |  11 +
 .../scheduler/adaptive/AdaptiveSchedulerTest.java  | 281 +++++++++++++--------
 .../runtime/scheduler/adaptive/CancelingTest.java  |   3 +-
 .../runtime/scheduler/adaptive/ExecutingTest.java  |  10 +-
 .../runtime/scheduler/adaptive/FailingTest.java    |   3 +-
 .../adaptive/StateWithExecutionGraphTest.java      |   4 +-
 .../scheduler/adaptive/StopWithSavepointTest.java  |  19 +-
 10 files changed, 248 insertions(+), 122 deletions(-)