This is an automated email from the ASF dual-hosted git repository.
dailai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new d2576ff131 [Hotfix][E2E] Fix OracleCDCIT compile error (#8023)
d2576ff131 is described below
commit d2576ff13112b0f845930374632a959cf29e7eb9
Author: hailin0 <[email protected]>
AuthorDate: Tue Nov 12 08:10:55 2024 +0800
[Hotfix][E2E] Fix OracleCDCIT compile error (#8023)
---
.../seatunnel/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 3376ed74bc..824608ce7a 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 class OracleCDCIT extends AbstractOracleCDCIT
implements TestResource {
"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 class OracleCDCIT extends AbstractOracleCDCIT
implements TestResource {
});
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(
