[flink] branch release-1.13 updated: [FLINK_22662][yarn][test] Add logs for YARNHighAvailabilityITCase

[xtsong]

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

xtsong pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 4dffdb6  [FLINK_22662][yarn][test] Add logs for 
YARNHighAvailabilityITCase
4dffdb6 is described below

commit 4dffdb6e1b2d509a27d3db6d07e4167656c5581d
Author: Xintong Song <tonysong...@gmail.com>
AuthorDate: Fri Jun 18 17:53:03 2021 +0800

    [FLINK_22662][yarn][test] Add logs for YARNHighAvailabilityITCase
    
    This closes #16197
---
 .../test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java  | 2 ++
 .../src/test/java/org/apache/flink/yarn/testjob/YarnTestJob.java     | 5 +++++
 2 files changed, 7 insertions(+)

diff --git 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
index 3bf29cf..ccd3461 100644
--- 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
+++ 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java
@@ -258,6 +258,7 @@ public class YARNHighAvailabilityITCase extends 
YarnTestBase {
                             >= attemptId;
                 },
                 Deadline.fromNow(TIMEOUT));
+        log.info("Attempt {} id detected.", attemptId);
     }
 
     /** Stops a container running {@link YarnTaskExecutorRunner}. */
@@ -319,6 +320,7 @@ public class YARNHighAvailabilityITCase extends 
YarnTestBase {
     private void waitForJobTermination(
             final RestClusterClient<ApplicationId> restClusterClient, final 
JobID jobId)
             throws Exception {
+        log.info("Sending stop job signal");
         stopJobSignal.signal();
         final CompletableFuture<JobResult> jobResult = 
restClusterClient.requestJobResult(jobId);
         jobResult.get(TIMEOUT.toMillis(), TimeUnit.MILLISECONDS);
diff --git 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/testjob/YarnTestJob.java 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/testjob/YarnTestJob.java
index a7c106c..419b75d 100644
--- 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/testjob/YarnTestJob.java
+++ 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/testjob/YarnTestJob.java
@@ -29,6 +29,8 @@ import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 
+import static org.apache.flink.util.Preconditions.checkState;
+
 /**
  * Testing job for {@link org.apache.flink.runtime.jobmaster.JobMaster} 
failover. Covering stream
  * case that have a infinite source and a sink, scheduling by EAGER mode, with 
PIPELINED edges.
@@ -63,6 +65,9 @@ public class YarnTestJob {
         /** Signals that the job should stop. */
         public void signal() {
             try {
+                checkState(
+                        Files.exists(Paths.get(stopJobMarkerFile)),
+                        "Marker file is deleted before signal.");
                 Files.delete(Paths.get(stopJobMarkerFile));
             } catch (final IOException e) {
                 throw new RuntimeException(e);