update codes

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

@@ -149,12 +149,11 @@ public class PortraitMonitorShdOperator implements BaseOperator{
                 long currentTimestamp = DateUtils.getCurrentTimestamp(date);
                 long tenMinitesAgoTimestamp = DateUtils.getTenMinitesAgoTimestamp(date);
                 for (Tuple2<String, JSONObject> tuple2 : elements) {
-                    System.err.println(tuple2.f0);
                     long logTime = 0;
                     JSONObject jsonObject = tuple2.f1;
                     String maidianEventTime = jsonObject.getString("create_at");
                     if (StringUtils.isNotBlank(maidianEventTime)) {
-                        logTime = Long.valueOf(maidianEventTime);
+                        logTime = Long.valueOf(maidianEventTime) * 1000;
                     }
                     String backendEventTime = jsonObject.getString("TIME");
                     if (StringUtils.isNotBlank(backendEventTime)) {
@@ -179,7 +178,6 @@ public class PortraitMonitorShdOperator implements BaseOperator{
                 }
             }
         });
-        process.print();
         process.addSink(new PortraitShdMysqlSink(outJdbcUrl,maxRetry,retryInteral))
                 .setParallelism(parallelism);
     }