[incubator-seatunnel] branch cdc-multiple-table updated: [Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch cdc-multiple-table
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/cdc-multiple-table by this 
push:
     new 9d088017a [Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule 
(#4194)
9d088017a is described below

commit 9d088017a300af59f28b4894a3009ad317b163f3
Author: Hisoka <fanjiaemi...@qq.com>
AuthorDate: Thu Feb 23 14:19:14 2023 +0800

    [Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)
---
 .../seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java
index 5ee18fda6..a609dc1c7 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java
@@ -59,11 +59,11 @@ public class JdbcSinkFactory implements TableSinkFactory {
                 BATCH_SIZE,
                 BATCH_INTERVAL_MS,
                 IS_EXACTLY_ONCE,
+                AUTO_COMMIT,
                 SUPPORT_UPSERT_BY_QUERY_PRIMARY_KEY_EXIST)
             .conditional(IS_EXACTLY_ONCE, true, XA_DATA_SOURCE_CLASS_NAME, 
MAX_COMMIT_ATTEMPTS, TRANSACTION_TIMEOUT_SEC)
             .conditional(IS_EXACTLY_ONCE, false, MAX_RETRIES)
             .conditional(SUPPORT_UPSERT_BY_QUERY_PRIMARY_KEY_EXIST, true, 
PRIMARY_KEYS)
-            .conditional(DRIVER, "com.teradata.jdbc.TeraDriver", AUTO_COMMIT)
             .build();
     }
 }