Skip to content

Commit cd910ed

Browse files
author
gituser
committed
Merge branch '1.8_release_3.10.x' into 1.8_release_4.0.x
2 parents 6b44bbd + 4e484f2 commit cd910ed

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

flinkx-rdb/flinkx-rdb-reader/src/main/java/com.dtstack.flinkx.rdb.inputformat/JdbcInputFormat.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -845,6 +845,8 @@ private void queryStartLocation() throws SQLException{
845845
//执行到此处代表轮询任务startLocation为空,且数据库中无数据,此时需要查询增量字段的最小值
846846
ps.setFetchDirection(ResultSet.FETCH_FORWARD);
847847
resultSet.close();
848+
//如果事务不提交 就会导致数据库即使插入数据 也无法读到数据
849+
dbConn.commit();
848850
resultSet = ps.executeQuery();
849851
hasNext = resultSet.next();
850852
//每隔五分钟打印一次

0 commit comments

Comments
 (0)