From 83f56d84a928240b78e8e19a826742ff62ef15c5 Mon Sep 17 00:00:00 2001 From: tangjiafu Date: Sat, 20 Aug 2022 16:56:13 +0800 Subject: [PATCH] update spell --- .../e2e/spark/v2/jdbc/dm/DMSourceTOConsoleIT.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/dm/DMSourceTOConsoleIT.java b/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/dm/DMSourceTOConsoleIT.java index def8ac44eed..0f78544b3c0 100644 --- a/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/dm/DMSourceTOConsoleIT.java +++ b/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/dm/DMSourceTOConsoleIT.java @@ -35,8 +35,8 @@ public class DMSourceTOConsoleIT extends SparkContainer { private static final String DATABASE = "SYSDBA"; private static final String TABLE = "e2e_table"; private static GenericContainer DMDB; - private static final int MAX_TRY_INIT = 10; - private static final int MAX_TRY_WAITTIME = 1000; + private static final int MAX_INIT_RETRY = 10; + private static final int MAX_INIT_RETRY_WAIT_TIME = 1000; @BeforeAll static void beforeAll() { @@ -49,12 +49,12 @@ static void beforeAll() { Startables.deepStart(Stream.of(DMDB)).join(); log.info("dm container started"); Class.forName(DRIVER_CLASS); - for (int i = 0; i < MAX_TRY_INIT; i++) { + for (int i = 0; i < MAX_INIT_RETRY; i++) { try { initializeJdbcTable(); break; } catch (Exception ignore) { - Thread.sleep(MAX_TRY_WAITTIME); + Thread.sleep(MAX_INIT_RETRY_WAIT_TIME); } } log.info("dm container init success: create table and insert data");