Merge branch '1.8_release_4.0.x' into 1.10_release_4.0.x

Author: gituser

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

@@ -816,6 +816,8 @@ private void queryStartLocation() throws SQLException{
                 //执行到此处代表轮询任务startLocation为空，且数据库中无数据，此时需要查询增量字段的最小值
                 ps.setFetchDirection(ResultSet.FETCH_FORWARD);
                 resultSet.close();
+                //如果事务不提交 就会导致数据库即使插入数据 也无法读到数据
+                dbConn.commit();
                 resultSet = ps.executeQuery();
                 hasNext = resultSet.next();
                 //每隔五分钟打印一次，(当前时间 - 任务开始时间) % 300秒 <= 一个间隔轮询周期