diff --git a/eventmesh-connectors/eventmesh-connector-canal/build.gradle b/eventmesh-connectors/eventmesh-connector-canal/build.gradle
index 94d85ee22b..134af8ed3e 100644
--- 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/eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java b/eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java
index 0508b291b9..027bc7e15b 100644
--- a/eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java
+++ b/eventmesh-connectors/eventmesh-connector-canal/src/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);