@PostConstruct
    private void startSaveSnapshotTask() {
        if (snapshotQueue == null) {
            snapshotQueue = new LinkedBlockingQueue<>(queueSize);
        }
        SaveSnapshotTaskRunnable taskRunnable = new SaveSnapshotTaskRunnable();
        EXECUTOR_SERVICE.execute(taskRunnable);
        LOGGER.info("source snapshot operate thread started successfully");
    }
Start a thread to operate source snapshot after the app started.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/SourceSnapshotOperator.java