dirty record inc

Author: todd5167

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

@@ -203,6 +203,7 @@ private void writeSingleRecord(Row row) {
             upload.execute();
             dbConn.commit();
         } catch (SQLException e) {
+            outDirtyRecords.inc();
             if (outDirtyRecords.getCount() % dirtyDataPrintFrequency == 0) {
                 LOG.error("record insert failed ..", row.toString());
                 LOG.error("", e);