[Hotfix][E2E] Fix OracleCDCIT compile error (#8023)

apache · Nov 12, 2024 · d2576ff · d2576ff
1 parent 9a24fac
commit d2576ff
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...e-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/OracleCDCIT.java b/...e-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(