update codes

bin/start.sh

@@ -31,7 +31,7 @@ $JAR_DIR/flink-monitor-1.0-SNAPSHOT.jar \
 --retryInteral 3000 \
 --checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/flink-monitor/checkpoint' \
 --parallelism 12 \
---startTime '2020-03-26 15:32:00' \
+--startTime '2020-03-26 15:40:00' \
 >> /data/log/flink-monitor/flink-monitor.out 2>&1 &
 
 tail -10f /data/log/flink-monitor/flink-monitor.out

src/main/java/com/gmei/data/monitor/operator/PortraitMonitorShdOperator.java

@@ -5,7 +5,6 @@ import com.alibaba.fastjson.JSONObject;
 import com.gmei.data.monitor.bean.DeviceInfo;
 import com.gmei.data.monitor.bean.TblMonitorPortraitShd;
 import com.gmei.data.monitor.cache.SimpleCacheService;
-import com.gmei.data.monitor.callable.DeviceCallable;
 import com.gmei.data.monitor.sink.PortraitShdMysqlSink;
 import com.gmei.data.monitor.utils.DateUtils;
 import com.gmei.data.monitor.utils.MysqlUtils;

src/main/java/com/gmei/data/monitor/utils/MysqlUtils.java

@@ -4,12 +4,16 @@ import com.gmei.data.monitor.common.Constants;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.Serializable;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 
-public class MysqlUtils {
+/**
+ * @author apple
+ */
+public class MysqlUtils implements Serializable {
 
 	private String jdbcUrl;
 	private static final Logger logger = LoggerFactory.getLogger(MysqlUtils.class);
@@ -36,7 +40,7 @@ public class MysqlUtils {
 			ps.close();
 			connection.close();
 		}catch (Exception e){
-
+			logger.error(e.getMessage());
 		}
 		return rs;
 	}