update codes

bin/start.sh

@@ -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 6 \
---startTime '2020-04-04 10:53:00' \
+--startTime '2020-04-04 10:55:00' \
 >> /data/log/ctr-estimate/ctr-estimate.out 2>&1 &
 
 tail -10f /data/log/ctr-estimate/ctr-estimate.out

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

@@ -83,7 +83,6 @@ public class CtrEstimateClkMysqlSink extends RichSinkFunction<DeviceCurrentEstim
                 newDeviceCurrentEstimateClk.setContentCardClick(resultSet.getLong("content_card_click") + deviceCurrentEstimateClk.getContentCardClick());
                 newDeviceCurrentEstimateClk.setTractateCardClick(resultSet.getLong("tractate_card_click") + deviceCurrentEstimateClk.getTractateCardClick());
                 newDeviceCurrentEstimateClk.setPartitionDate(resultSet.getString("partition_date"));
-                newDeviceCurrentEstimateClk.setLastUpdateTime(DateUtils.getTimeStr(new Date()));
             }
             if(null != newDeviceCurrentEstimateClk){
                 statement.executeUpdate(String.format("update device_current_estimate_clk set " +
@@ -95,7 +94,7 @@ public class CtrEstimateClkMysqlSink extends RichSinkFunction<DeviceCurrentEstim
                         newDeviceCurrentEstimateClk.getAnswerCardClick(),
                         newDeviceCurrentEstimateClk.getContentCardClick(),
                         newDeviceCurrentEstimateClk.getTractateCardClick(),
-                        newDeviceCurrentEstimateClk.getLastUpdateTime(),
+                        DateUtils.getTimeStr(new Date()),
                         newDeviceCurrentEstimateClk.getDeviceId(),
                         newDeviceCurrentEstimateClk.getPartitionDate()
                     )