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