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