配置文件修改

fs-sync/src/main/java/com/fs/fssync/listener/MySqlEventListener.java

@@ -40,7 +40,7 @@ public class MySqlEventListener implements CommandLineRunner {
     private FlinkConfig flinkConfig;
 
     private static final String JOB_ID = "1a2b3c4d5e6f7a8b9c0d1e2f3a4b5c6d";
-    private static final String CHECKPOINT_DIR = "d:/data/flink/checkpoints";
+    private static final String CHECKPOINT_DIR = "file:///d:/data/flink/checkpoints";
 
     @Override
     public void run(String... args) throws Exception {