You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/05/28 12:04:03 UTC
[flink] branch master updated (0179156 -> 44fba5f)

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 0179156  [FLINK-17986] Fix check in FsCheckpointStateOutputStream.write
     add 3717948  [hotfix][tests] Remove unused TestingScheduledExecutor
     add 484bba5  [hotfix][tests] Shutdown TaskmanagerServices
     add 90b8455  [FLINK-17558][runtime] Add Executors#newCachedThreadPool
     add 3a49e89  [FLINK-17558][tests] Simplify partition tracker setup
     add 67d89e7  [FLINK-17558][tests] Extract ShuffleEnvironment/PartitionTracker setup
     add 44fba5f  [FLINK-17558][netty] Release partitions asynchronously

No new revisions were added by this update.

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