From d2576ff13112b0f845930374632a959cf29e7eb9 Mon Sep 17 00:00:00 2001 From: hailin0 Date: Tue, 12 Nov 2024 08:10:55 +0800 Subject: [PATCH] [Hotfix][E2E] Fix OracleCDCIT compile error (#8023) --- .../connectors/seatunnel/cdc/oracle/OracleCDCIT.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/OracleCDCIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/OracleCDCIT.java index 3376ed74bcc..824608ce7ab 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/OracleCDCIT.java +++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-oracle-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/OracleCDCIT.java @@ -261,10 +261,10 @@ public void testOracleCdcCheckDataWithCustomPrimaryKey(TestContainer container) "This case requires obtaining the task health status and manually canceling the canceled task, which is currently only supported by the zeta engine.") public void testOracleCdcMetadataTrans(TestContainer container) throws Exception { - clearTable(DATABASE, SOURCE_TABLE_NO_PRIMARY_KEY); - clearTable(DATABASE, SINK_TABLE1); + clearTable(SCEHMA_NAME, SOURCE_TABLE_NO_PRIMARY_KEY); + clearTable(SCEHMA_NAME, SINK_TABLE1); - insertSourceTable(DATABASE, SOURCE_TABLE_NO_PRIMARY_KEY); + insertSourceTable(SCEHMA_NAME, SOURCE_TABLE_NO_PRIMARY_KEY); Long jobId = JobIdGenerator.newJobId(); CompletableFuture.supplyAsync( () -> { @@ -279,7 +279,7 @@ public void testOracleCdcMetadataTrans(TestContainer container) throws Exception }); TimeUnit.SECONDS.sleep(10); // insert update delete - updateSourceTable(DATABASE, SOURCE_TABLE_NO_PRIMARY_KEY); + updateSourceTable(SCEHMA_NAME, SOURCE_TABLE_NO_PRIMARY_KEY); TimeUnit.SECONDS.sleep(20); await().atMost(2, TimeUnit.MINUTES) .untilAsserted(