fix commit execute

apache · Jul 23, 2024 · 7d54630 · 7d54630
1 parent 37e7078
commit 7d54630
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/eventmesh-connectors/eventmesh-connector-canal/build.gradle b/eventmesh-connectors/eventmesh-connector-canal/build.gradle
@@ -23,7 +23,7 @@ List canal = [
 
 dependencies {
     api project(":eventmesh-openconnect:eventmesh-openconnect-java")
-    implementation "org.locationtech.jts"
+    implementation "org.locationtech.jts:jts-core"
     implementation project(":eventmesh-common")
     implementation canal
     implementation "com.alibaba:druid"

diff --git a/...main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java b/...main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java
@@ -136,6 +136,7 @@ public void put(List<ConnectRecord> sinkRecords) {
                 statement.addBatch();
             }
             statement.executeBatch();
+            connection.commit();
         } catch (SQLException e) {
             log.warn("full sink process schema [{}] table [{}] connector write fail", tableDefinition.getSchemaName(),tableDefinition.getTableName(),
                 e);