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 3376ed74bcc1..824608ce7ab5 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(