diff --git a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2StarRocksTest.java b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2StarRocksTest.java index 1564967447..9eeabc5849 100644 --- a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2StarRocksTest.java +++ b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2StarRocksTest.java @@ -87,7 +87,7 @@ public class Pulsar2StarRocksTest extends FlinkContainerTestEnvJRE8 { .withLogConsumer(new Slf4jLogConsumer(STAR_ROCKS_LOG)); @Before - public void setup() throws { + public void setup() { waitUntilJobRunning(Duration.ofSeconds(30)); initializePulsarTopic(); initializeStarRocksTable(STAR_ROCKS);