[seatunnel] branch dev updated: [Improve] Optimize Test Cases `CheckpointTimeOutTest.testJobLevelCheckpointTimeOut` (#5403)

[fanjia]

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

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b3ba5eb273 [Improve] Optimize Test Cases 
`CheckpointTimeOutTest.testJobLevelCheckpointTimeOut` (#5403)
b3ba5eb273 is described below

commit b3ba5eb273d944b7eb845495e92b4eb63b29a877
Author: Guangdong Liu <804167...@qq.com>
AuthorDate: Thu Aug 31 19:03:50 2023 +0800

    [Improve] Optimize Test Cases 
`CheckpointTimeOutTest.testJobLevelCheckpointTimeOut` (#5403)
---
 .../server/checkpoint/CheckpointTimeOutTest.java   | 24 ++++++++++++----------
 1 file changed, 13 insertions(+), 11 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointTimeOutTest.java
 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointTimeOutTest.java
index ed2b4dbb6d..3cf7636adf 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointTimeOutTest.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointTimeOutTest.java
@@ -28,12 +28,14 @@ import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
 import com.hazelcast.internal.serialization.Data;
+import lombok.extern.slf4j.Slf4j;
 
 import java.util.Collections;
 import java.util.concurrent.TimeUnit;
 
 import static org.awaitility.Awaitility.await;
 
+@Slf4j
 public class CheckpointTimeOutTest extends AbstractSeaTunnelServerTest {
 
     public static String CONF_PATH = 
"stream_fake_to_console_checkpointTimeOut.conf";
@@ -45,20 +47,20 @@ public class CheckpointTimeOutTest extends 
AbstractSeaTunnelServerTest {
 
         await().atMost(120000, TimeUnit.MILLISECONDS)
                 .untilAsserted(
-                        () -> {
-                            Assertions.assertTrue(
-                                    server.getCoordinatorService()
-                                            .getJobStatus(JOB_ID)
-                                            .equals(JobStatus.RUNNING));
-                        });
+                        () ->
+                                Assertions.assertEquals(
+                                        
server.getCoordinatorService().getJobStatus(JOB_ID),
+                                        JobStatus.RUNNING));
 
-        await().atMost(120000, TimeUnit.MILLISECONDS)
+        await().atMost(360000, TimeUnit.MILLISECONDS)
                 .untilAsserted(
                         () -> {
-                            Assertions.assertTrue(
-                                    server.getCoordinatorService()
-                                            .getJobStatus(JOB_ID)
-                                            .equals(JobStatus.FAILED));
+                            log.info(
+                                    "Job status: {}",
+                                    
server.getCoordinatorService().getJobStatus(JOB_ID));
+                            Assertions.assertEquals(
+                                    
server.getCoordinatorService().getJobStatus(JOB_ID),
+                                    JobStatus.FAILED);
                         });
     }