update codes

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

@@ -28,7 +28,7 @@ public class TestCtrEstimateMainPfr {
         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-tag/checkpoint");
-        Boolean isStartFromEarliest = parameterTool.getBoolean("isStartFromEarliest",true);
+        Boolean isStartFromEarliest = parameterTool.getBoolean("isStartFromEarliest",false);
         Boolean isStartFromLatest = parameterTool.getBoolean("isStartFromLatest",false);
         String startTime = parameterTool.get("startTime");
         Integer parallelism = parameterTool.getInt("parallelism",3);

src/main/java/com/gmei/data/ctr/operator/CtrEstimatePfrOperator.java

@@ -165,6 +165,6 @@ public class CtrEstimatePfrOperator implements BaseOperator{
 
         tidbAsyncDataStream
         .addSink(new CtrEstimatePfrMysqlSink(outJdbcUrl, maxRetry, retryInteral))
-        .setParallelism(parallelism);
+        .setParallelism(1);
     }
 }