Merge branch 'hotfix_1.8_3.10.x_27306' into 1.8_release_3.10.x

Author: gituser

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/JDBCTypeConvertUtils.java

@@ -106,7 +106,7 @@ public static void setField(PreparedStatement upload, int type, Object field, in
 						break;
 					case java.sql.Types.FLOAT:
 					case java.sql.Types.DOUBLE:
-						upload.setDouble(index + 1, (double) field);
+						upload.setDouble(index + 1, Double.parseDouble(field.toString()));
 						break;
 					case java.sql.Types.DECIMAL:
 					case java.sql.Types.NUMERIC:

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/writer/AppendOnlyWriter.java

@@ -118,11 +118,11 @@ public void executeUpdate(Connection connection)  {
                 } catch (SQLException e1) {
                     throw new RuntimeException(e1);
                 }
-                metricOutputFormat.outDirtyRecords.inc();
                 if (metricOutputFormat.outDirtyRecords.getCount() % DIRTYDATA_PRINT_FREQUENTY == 0 || LOG.isDebugEnabled()) {
                     LOG.error("record insert failed ,this row is {}", row.toString());
                     LOG.error("", e);
                 }
+                metricOutputFormat.outDirtyRecords.inc();
             }
         });
         rows.clear();