add checkpointPath

ml_c_et_pe_preciseexposure_dimem_d_rt/src/main/java/com/gmei/streaming/PreciseExposureStreaming.java

@@ -74,7 +74,7 @@ public class PreciseExposureStreaming {
             windowSize = parameterTool.getInt("windowSize", 30);
             parallelism = parameterTool.getInt("parallelism", 1);
             startTime = parameterTool.get("startTime", null);
-            checkpointPath = parameterTool.getRequired("/user/data/flink/{程序名}/checkpoint");
+            checkpointPath = parameterTool.getRequired("checkpointPath");
             printUsage(parameterTool);
         } catch (Exception e) {
             e.printStackTrace();
@@ -189,7 +189,8 @@ public class PreciseExposureStreaming {
                 "    --sinkJdbcUrl <target database url> \n" +
                 "    --sinkTableName <target table name> \n" +
                 "    --parallelism <parallelism, default 1> \n" +
-                "    --startTime <startTime, default 1> \n"
+                "    --startTime <kafka startTime, default null> \n" +
+                "    --checkpointPath <checkpointPath, hdfs> \n"
         );
     }
 
@@ -215,7 +216,8 @@ public class PreciseExposureStreaming {
                 "    --sinkJdbcUrl " + parameterTool.getRequired("sinkJdbcUrl") + " \n" +
                 "    --sinkTableName " + parameterTool.getRequired("sinkTableName") + " \n" +
                 "    --parallelism "+ parameterTool.getInt("parallelism", 1) + " \n" +
-                "    --startTime " + parameterTool.get("startTime", null) + " \n"
+                "    --startTime " + parameterTool.get("startTime", null) + " \n" +
+                "    --checkpointPath " + parameterTool.getRequired("checkpointPath") + " \n"
         );
     }