This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b379dd1 [FLINK-25924][connectors/firehose] Adding a timeout for the
LocalstackContainer
new 59ccc68 [hotfix] Migrates BlobServerCleanupTest to JUnit5/AssertJ
new 9cac582 [FLINK-25954][runtime] Adds cleanup testcases to
BlobServerCleanupTest
new 919dca5 [FLINK-25953][runtime] Reorganizes dispatcher cleanup related
tests
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:
.../DefaultJobManagerRunnerRegistry.java | 12 +-
.../flink/runtime/dispatcher/Dispatcher.java | 69 ++-
.../OnMainThreadJobManagerRunnerRegistry.java | 112 ++++
.../cleanup/DispatcherResourceCleanerFactory.java | 2 +-
.../flink/runtime/blob/BlobServerCleanupTest.java | 227 ++++++--
.../runtime/dispatcher/AbstractDispatcherTest.java | 137 +----
.../DefaultJobManagerRunnerRegistryTest.java | 5 +-
.../dispatcher/DispatcherFailoverITCase.java | 10 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 575 ++++++++++-----------
.../flink/runtime/dispatcher/DispatcherTest.java | 180 +------
.../runtime/dispatcher/TestingDispatcher.java | 281 ++++++++++
.../cleanup/TestingResourceCleanerFactory.java | 132 +++++
12 files changed, 1073 insertions(+), 669 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/OnMainThreadJobManagerRunnerRegistry.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/TestingResourceCleanerFactory.java
