diff --git a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobExecutionIT.java b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobExecutionIT.java index b666b994c7a..501e763e3c4 100644 --- a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobExecutionIT.java +++ b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobExecutionIT.java @@ -199,8 +199,7 @@ public void testExpiredJobWasDeleted() throws Exception { JobResult result = clientJobProxy.doWaitForJobComplete().get(); Assertions.assertEquals(result.getStatus(), JobStatus.FINISHED); - Awaitility.await() - .atMost(65, TimeUnit.SECONDS) + await().atMost(65, TimeUnit.SECONDS) .untilAsserted( () -> Assertions.assertThrowsExactly(