This is an automated email from the ASF dual-hosted git repository. xtsong pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 240a1e8 [FLINK-18883][python] Support reduce() operation for Python KeyedStream. (#13113) add 5debd15 [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster No new revisions were added by this update. Summary of changes: .../slotmanager/SlotManagerImpl.java | 5 +++- .../TaskManagerCheckInSlotManagerTest.java | 34 ++++++++++++++-------- 2 files changed, 26 insertions(+), 13 deletions(-)