update codes

pom.xml

@@ -207,7 +207,7 @@
                             </filters>
                             <transformers>
                                 <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
-                                    <mainClass>com.gmei.data.ctr.main.TestCtrEstimateMainTag</mainClass>
+                                    <mainClass>com.gmei.data.ctr.main.TestCtrEstimateMainPfr</mainClass>
                                 </transformer>
                             </transformers>
                             <createDependencyReducedPom>false</createDependencyReducedPom>

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

@@ -17,20 +17,20 @@ public class TestCtrEstimateMainPfr {
     public static void main(String[] args) throws Exception{
         // 获取运行参数
         ParameterTool parameterTool = ParameterTool.fromArgs(args);
-        String inBrokers = parameterTool.get("inBrokers","test003:9092");
+        String inBrokers = parameterTool.get("inBrokers","172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092");
         String batchSize = parameterTool.get("batchSize","1000");
-        String maidianInTopic = parameterTool.get("maidianInTopic", "test11");
-        String maidianInGroupId = parameterTool.get("maidianInGroupId","ctr-estimate-tag");
+        String maidianInTopic = parameterTool.get("maidianInTopic", "gm-maidian-data");
+        String maidianInGroupId = parameterTool.get("maidianInGroupId","test-ctr-estimate-pfr");
         Integer windowSize = parameterTool.getInt("windowSize",5);
         Integer slideSize = parameterTool.getInt("slideSize",5);
         String outJdbcUrl = parameterTool.get("outJdbcUrl",
                 "jdbc:mysql://172.18.44.3:3306/jerry_test?user=root&password=5OqYM^zLwotJ3oSo&autoReconnect=true&useSSL=false");
         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");
+        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");
+        String startTime = parameterTool.get("startTime","2020-04-04 20:42:00");
         Integer parallelism = parameterTool.getInt("parallelism",2);
         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");