feat: 配置同步服务

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

@@ -157,7 +157,7 @@ public class MySqlEventListener implements CommandLineRunner {
     }
 
     private String findLatestCheckpoint() {
-        File checkpointDir = new File("d:/data/flink/checkpoints/" + JOB_ID);
+        File checkpointDir = new File(CHECKPOINT_DIR + JOB_ID);
         if (!checkpointDir.exists() || !checkpointDir.isDirectory()) {
             return null;
         }
@@ -181,7 +181,7 @@ public class MySqlEventListener implements CommandLineRunner {
         File latest = checkpoints[0];
         File metadata = new File(latest, "_metadata");
         if (metadata.exists() && metadata.isFile()) {
-            return "file:///d:/data/flink/checkpoints/" + JOB_ID + "/" + latest.getName();
+            return CHECKPOINT_DIR + JOB_ID + "/" + latest.getName();
         }
 
         return null;