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 18055bb [hotfix][python][docs] Correct the docs of interval join
add 62a342b [FLINK-22676][coordination] The partition tracker stops
tracking internal partitions when TM disconnects
No new revisions were added by this update.
Summary of changes:
.../partition/AbstractPartitionTracker.java | 11 +-
.../partition/JobMasterPartitionTracker.java | 14 +-
.../partition/JobMasterPartitionTrackerImpl.java | 72 ++++---
.../apache/flink/runtime/jobmaster/JobMaster.java | 22 +-
.../partition/AbstractPartitionTrackerTest.java | 2 +-
.../JobMasterPartitionTrackerImplTest.java | 235 +++++++++++----------
.../partition/NoOpJobMasterPartitionTracker.java | 15 +-
.../TestingJobMasterPartitionTracker.java | 37 ++--
.../jobmaster/JobMasterPartitionReleaseTest.java | 66 ++++--
9 files changed, 274 insertions(+), 200 deletions(-)
