Merge branch 'v1.5.0_dev' of ssh://git.dtstack.cn:10022/dtstack/dt-center-flinkStreamSQL into 1.5.0_dev_field_as

Author: todd5167

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

@@ -40,6 +40,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import com.dtstack.flink.sql.sink.MetricOutputFormat;
+import sun.rmi.runtime.Log;
 
 /**
  * OutputFormat to write tuples into a database.
@@ -117,8 +118,10 @@ public void open(int taskNumber, int numTasks) throws IOException {
             }
 
         } catch (SQLException sqe) {
+            LOG.error("", sqe);
             throw new IllegalArgumentException("open() failed.", sqe);
         } catch (ClassNotFoundException cnfe) {
+            LOG.error("", cnfe);
             throw new IllegalArgumentException("JDBC driver class not found.", cnfe);
         }
     }
@@ -271,6 +274,7 @@ private void updatePreparedStmt(Row row, PreparedStatement pstmt) throws SQLExce
 
     private synchronized void submitExecuteBatch() {
         try {
+            LOG.info("submitExecuteBatch start......");
             this.upload.executeBatch();
             this.batchCount.set(0);
         } catch (SQLException e) {