update codes

bin/start.sh

@@ -9,9 +9,9 @@ nohup $FLINK_HOME/bin/flink run  \
 -m yarn-cluster \
 -ynm ctr-estimate \
 -yqu flink \
--yn 2 \
--ys 2 \
--p 4 \
+-yn 3 \
+-ys 3 \
+-p 6 \
 -yjm 1024 \
 -ytm 2048 \
 $JAR_DIR/ctr-estimate-1.0-SNAPSHOT.jar \
@@ -26,7 +26,7 @@ $JAR_DIR/ctr-estimate-1.0-SNAPSHOT.jar \
 --retryInteral 3000 \
 --checkpointPath 'hdfs://bj-gmei-hdfs/user/data/flink/ctr-estimate/checkpoint' \
 --parallelism 12 \
---startTime '2020-04-03 20:30:00' \
+--startTime '2020-04-03 20:40:00' \
 >> /data/log/ctr-estimate/ctr-estimate.out 2>&1 &
 
 tail -10f /data/log/ctr-estimate/ctr-estimate.out