update codes

src/main/java/com/gmei/data/ctr/main/TestCtrEstimateMainPfr.java

@@ -30,8 +30,8 @@ public class TestCtrEstimateMainPfr {
         String checkpointPath = parameterTool.get("checkpointPath","hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate-tag/checkpoint");
         Boolean isStartFromEarliest = parameterTool.getBoolean("isStartFromEarliest",true);
         Boolean isStartFromLatest = parameterTool.getBoolean("isStartFromLatest",false);
-        String startTime = parameterTool.get("startTime","2020-04-04 20:42:00");
-        Integer parallelism = parameterTool.getInt("parallelism",2);
+        String startTime = parameterTool.get("startTime");
+        Integer parallelism = parameterTool.getInt("parallelism",3);
         String inJerryJdbcUrl = parameterTool.get("inJerryJdbcUrl","jdbc:mysql://172.16.40.170:4000/jerry_test?characterEncoding=UTF-8&autoReconnect=true&useSSL=false");
         String inJerryUsername = parameterTool.get("inJerryUsername","data_user");
         String inJerryPassword = parameterTool.get("inJerryPassword","YPEzp78HQBuhByWPpefQu6X3D6hEPfD6");

src/main/java/com/gmei/data/ctr/sink/CtrEstimatePfrMysqlSink.java

@@ -150,7 +150,6 @@ public class CtrEstimatePfrMysqlSink extends RichSinkFunction<DeviceCurrentEstim
                             DateUtils.getSevenDaysAgoTimeStr(date)
                     )
             );
-            System.out.println(deviceCurrentEstimatePfrTmp);
         }catch (Exception e){
             e.printStackTrace();
         }finally {