update codes

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

@@ -46,6 +46,9 @@ public class ProdCtrPfrRctMain {
         System.out.println("*** startTime: " + startTime);
         System.out.println("*** windowSize: " + windowSize);
         System.out.println("*** slideSize: " + slideSize);
+        System.out.println("*** inJerryJdbcUrl: " + inJerryJdbcUrl);
+        System.out.println("*** inJerryUsername: " + inJerryUsername);
+        System.out.println("*** inJerryPassword: " + inJerryPassword);
         System.out.println("**********************************************************");
         // 获得流处理环境对象
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

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

@@ -32,7 +32,7 @@ public class ProdCtrTagCrtMain {
         Integer maxRetry = parameterTool.getInt("maxRetry",3);
         Long retryInteral = parameterTool.getLong("retryInteral",3000);
         String checkpointPath = parameterTool.get("checkpointPath","hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate/checkpoint");
-        Boolean isStartFromEarliest = parameterTool.getBoolean("isStartFromEarliest",true);
+        Boolean isStartFromEarliest = parameterTool.getBoolean("isStartFromEarliest",false);
         Boolean isStartFromLatest = parameterTool.getBoolean("isStartFromLatest",true);
         String startTime = parameterTool.get("startTime");
         Integer parallelism = parameterTool.getInt("parallelism",2);

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

@@ -41,6 +41,9 @@ public class TestCtrPfrRctMain {
         System.out.println("*** outJdbcUrl: " + outJdbcUrl);
         System.out.println("*** checkpointPath: " + checkpointPath);
         System.out.println("*** startTime: " + startTime);
+        System.out.println("*** inJerryJdbcUrl: " + inJerryJdbcUrl);
+        System.out.println("*** inJerryUsername: " + inJerryUsername);
+        System.out.println("*** inJerryPassword: " + inJerryPassword);
         System.out.println("**********************************************************");
         // 获得流处理环境对象
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();