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 2e98b3f [hotfix][source] Use only one watermark class in
SourceOperatorEventTimeTest.
add b67865b [FLINK-25277][flink-runtime] add shutdown hook to stop
TaskExecutor on SIGTERM
add d09bf45 [FLINK-25277][flink-runtime] synchronize termination and
release of containers in YARNResourceManagerDriver
No new revisions were added by this update.
Summary of changes:
.../StandaloneResourceManagerFactory.java | 4 +-
.../active/ResourceManagerDriverTestBase.java | 5 +
...tractTaskManagerProcessFailureRecoveryTest.java | 29 +--
.../recovery/ProcessFailureCancelingITCase.java | 2 +-
.../TaskManagerDisconnectOnShutdownITCase.java | 266 +++++++++++++++++++++
.../test/recovery/TaskManagerRunnerITCase.java | 11 +-
.../utils/TaskExecutorProcessEntryPoint.java | 49 ++++
.../flink/yarn/YarnResourceManagerDriver.java | 11 +
.../flink/yarn/YarnResourceManagerDriverTest.java | 140 ++++++++++-
.../src/test/resources/log4j2-test.properties | 2 +-
10 files changed, 478 insertions(+), 41 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerDisconnectOnShutdownITCase.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/recovery/utils/TaskExecutorProcessEntryPoint.java
