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 2022/07/26 05:44:33 UTC

[flink] branch master updated (7ea31cfcf36 -> 64ad6709f41)

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 7ea31cfcf36 [FLINK-28549][python] Support DataStream PythonProcessOperator in Thread Mode
     add 64ad6709f41 [FLINK-28660][runtime] Simplify logs of blocklist

No new revisions were added by this update.

Summary of changes:
 ...istener.java => BlockedNodeAdditionResult.java} | 38 ++++++++++++-------
 .../flink/runtime/blocklist/BlocklistTracker.java  |  4 +-
 .../runtime/blocklist/DefaultBlocklistHandler.java | 26 ++++++++-----
 .../runtime/blocklist/DefaultBlocklistTracker.java | 43 ++++++++++++++++------
 .../blocklist/DefaultBlocklistTrackerTest.java     | 10 +++--
 5 files changed, 80 insertions(+), 41 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/blocklist/{BlocklistListener.java => BlockedNodeAdditionResult.java} (52%)