This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 442ab0ce6cb [FLINK-29210][Docs][SQL Client] Copy English Docker documentation to Chinese documentation to bring them back in sync new a901911266b [FLINK-28860][datastream] Cache consumption in stream mode recompute result in case of cache miss new 3d05f275225 [hotfix][datastream] Fix cache invalidate with remote session cluster new b7dd42617a4 [FLINK-28860][runtime] JobMaster wait for partition promote before close The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../executors/AbstractSessionClusterExecutor.java | 2 +- .../partition/JobMasterPartitionTracker.java | 27 ++- .../partition/JobMasterPartitionTrackerImpl.java | 89 +++----- .../TaskExecutorPartitionTrackerImpl.java | 10 + .../apache/flink/runtime/jobmaster/JobMaster.java | 46 ++-- .../runtime/jobmaster/RpcTaskManagerGateway.java | 3 +- .../dataset/ClusterDataSetDeleteHandlers.java | 2 +- .../flink/runtime/taskexecutor/TaskExecutor.java | 33 ++- .../runtime/taskexecutor/TaskExecutorGateway.java | 20 +- .../TaskExecutorGatewayDecoratorBase.java | 13 +- .../JobMasterPartitionTrackerImplTest.java | 239 +++++++++++++-------- .../partition/NoOpJobMasterPartitionTracker.java | 7 +- .../TestingJobMasterPartitionTracker.java | 31 +-- .../jobmaster/JobMasterPartitionReleaseTest.java | 19 +- .../TaskExecutorPartitionLifecycleTest.java | 28 +-- .../taskexecutor/TestingTaskExecutorGateway.java | 27 +-- .../TestingTaskExecutorGatewayBuilder.java | 30 ++- .../translators/CacheTransformationTranslator.java | 6 +- .../api/graph/StreamGraphGeneratorTest.java | 17 -- .../flink/test/streaming/runtime/CacheITCase.java | 141 +++++------- 20 files changed, 434 insertions(+), 356 deletions(-)