We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6505da6 commit b2b0877Copy full SHA for b2b0877
1 file changed
rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/format/RetractJDBCOutputFormat.java
@@ -198,6 +198,7 @@ private void writeSingleRecord(Row row) {
198
try {
199
updatePreparedStmt(row, upload);
200
upload.execute();
201
+ dbConn.commit();
202
} catch (SQLException e) {
203
outDirtyRecords.inc();
204
LOG.error("record insert failed ..", row.toString());
0 commit comments