添加日志

src/main/java/com/dsk/flink/dsc/common/sink/MysqlDataTransferSinkBatch.java

@@ -102,7 +102,7 @@ public class MysqlDataTransferSinkBatch extends RichSinkFunction<String> {
                             } catch (Exception ex) {
                                 logger.error("事务回滚异常", ex);
                             }
-                            logger.error("------错误时间:{}-----,sql:{}--------异常:{}", new Date(), String.join(";", batch), e);
+                            logger.error("------错误时间:{}-------------异常:", new Date(), e);
                             SqlErrorLog errorLog = new SqlErrorLog(new Date(), String.join(";", batch), e.getMessage());
                             writeErrLogDb(errorLog);
                         }