You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/12/10 16:38:25 UTC
[flink] branch master updated (5776483 -> cf1e8c3)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5776483 [FLINK-25126][kafka] Reset internal transaction state of FlinkKafkaInternalProducer if transaction finalization fails
add cf1e8c3 [FLINK-25257][TE] Let TaskExecutor use TaskExecutorBlobService interface instead of concrete BlobCacheService implementation
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/blob/BlobCacheService.java | 2 +-
.../JobPermanentBlobService.java} | 32 ++++++++++---------
.../flink/runtime/blob/PermanentBlobCache.java | 4 ++-
.../runtime/blob/TaskExecutorBlobService.java} | 20 +++++++-----
.../flink/runtime/taskexecutor/TaskExecutor.java | 24 ++++++++-------
.../runtime/taskexecutor/TaskManagerRunner.java | 7 +++--
...rvice.java => NoOpJobPermanentBlobService.java} | 20 +++++++++---
.../runtime/blob/NoOpTaskExecutorBlobService.java} | 36 +++++++++++-----------
...cutorExecutionDeploymentReconciliationTest.java | 5 ++-
.../TaskExecutorPartitionLifecycleTest.java | 5 ++-
.../taskexecutor/TaskExecutorSlotLifetimeTest.java | 5 ++-
.../runtime/taskexecutor/TaskExecutorTest.java | 17 ++--------
.../taskexecutor/TaskManagerRunnerStartupTest.java | 5 ++-
.../TaskSubmissionTestEnvironment.java | 12 ++++----
.../runtime/taskexecutor/TestingTaskExecutor.java | 6 ++--
15 files changed, 104 insertions(+), 96 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{jobmanager/ThrowingJobGraphWriter.java => blob/JobPermanentBlobService.java} (59%)
copy flink-runtime/src/{test/java/org/apache/flink/runtime/checkpoint/NoOpFailJobCall.java => main/java/org/apache/flink/runtime/blob/TaskExecutorBlobService.java} (62%)
copy flink-runtime/src/test/java/org/apache/flink/runtime/blob/{VoidPermanentBlobService.java => NoOpJobPermanentBlobService.java} (69%)
copy flink-runtime/src/{main/java/org/apache/flink/runtime/blob/VoidBlobStore.java => test/java/org/apache/flink/runtime/blob/NoOpTaskExecutorBlobService.java} (53%)