This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 00ca13b [FLINK-17882][table-common] Check for self references in
structured types
new 49fedef [hotfix][tests] Remove unused TestingScheduledExecutor
new b8ccab2 [hotfix][tests] Shutdown TaskmanagerServices
new 6bc156b [FLINK-17558][tests] Add TestExecutorResource
new c40a541 [FLINK-17558][runtime] Add Executors#newCachedThreadPool
new 7fdd488 [FLINK-17558][tests] Simplify partition tracker setup
new a8145e5 [FLINK-17558][tests] Extract
ShuffleEnvironment/PartitionTracker setup
new 79cb1a1 [FLINK-17558][netty] Release partitions asynchronously
The 7 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:
.../apache/flink/runtime/concurrent/Executors.java | 27 +++++
.../io/network/NettyShuffleEnvironment.java | 15 ++-
.../io/network/NettyShuffleServiceFactory.java | 31 ++++-
.../runtime/shuffle/ShuffleEnvironmentContext.java | 11 +-
.../runtime/taskexecutor/TaskManagerRunner.java | 7 +-
.../runtime/taskexecutor/TaskManagerServices.java | 19 ++-
.../TaskManagerServicesConfiguration.java | 18 ++-
.../flink/runtime/concurrent/ExecutorsTest.java | 63 ++++++++++
.../io/network/NettyShuffleEnvironmentBuilder.java | 21 +++-
.../io/network/NettyShuffleEnvironmentTest.java | 26 +++++
.../TaskExecutorLocalStateStoresManagerTest.java | 58 +++++----
.../TaskExecutorPartitionLifecycleTest.java | 129 +++++++++++++++------
.../runtime/util/TestingScheduledExecutor.java | 62 ----------
.../testutils/executor/TestExecutorResource.java | 42 ++++---
14 files changed, 363 insertions(+), 166 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ExecutorsTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingScheduledExecutor.java
copy
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateDataTransfer.java
=>
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/executor/TestExecutorResource.java
(51%)
