This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f90493f [FLINK-22142][ci] Don't log Kafka connector output to the AZP
console
add b653222 [hotfix][test] Add error message for
CommonTestUtils#waitUntilCondition
add e3066e4 [FLINK-21148][test] Removes runTest in runDetachedModeTest
add 7c7f7fe [FLINK-21148][test] Makes the test fail early when running
into a timeout
add 9250c4a [FLINK-21148][test] Increases timeout
add 6f1e1b5 [FLINK-21148][test] Refactors test code to use
CommonTestUtils for loops
add 278839b [hotfix][yarn-tests] Check the applicationId in
verifyStringsInNamedLogFiles
add 35babaf [FLINK-21008][coordination] Register
ClusterEntrypoint#closeAsync as shutdown hook for the cleanup
No new revisions were added by this update.
Summary of changes:
.../runtime/entrypoint/ClusterEntrypoint.java | 43 ++-
.../DispatcherResourceManagerComponent.java | 28 +-
.../runtime/entrypoint/ClusterEntrypointTest.java | 424 +++++++++++++++++++++
.../TestingHighAvailabilityServices.java | 18 +-
.../TestingHighAvailabilityServicesBuilder.java | 21 +
.../flink/runtime/testutils/CommonTestUtils.java | 18 +-
.../flink/runtime/testutils/TestJvmProcess.java | 19 +
.../testutils/TestingClusterEntrypointProcess.java | 138 +++++++
.../flink/runtime/util/BlockingShutdownTest.java | 11 +-
.../recovery/ProcessFailureCancelingITCase.java | 2 +-
.../apache/flink/yarn/YARNSessionFIFOITCase.java | 308 +++++++--------
.../flink/yarn/YARNSessionFIFOSecuredITCase.java | 16 +-
.../java/org/apache/flink/yarn/YarnTestBase.java | 18 +-
13 files changed, 868 insertions(+), 196 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/TestingClusterEntrypointProcess.java
