fix style

laglangyue · Sep 14, 2023 · 3974773 · 3974773
1 parent 2378e77
commit 3974773
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...he/seatunnel/translation/spark/source/reader/micro/ParallelMicroBatchPartitionReader.java b/...he/seatunnel/translation/spark/source/reader/micro/ParallelMicroBatchPartitionReader.java
@@ -107,6 +107,7 @@ protected FileSystem getFileSystem()
     protected ReaderState snapshotState() {
         Map<Integer, List<byte[]>> bytes;
         try {
+            // 枚举器的状态
             bytes = internalSource.snapshotState(checkpointId);
         } catch (Exception e) {
             throw new RuntimeException(e);
@@ -115,6 +116,7 @@ protected ReaderState snapshotState() {
     }
 
     public void prepareCheckpoint() {
+        // 定时任务去 virtualCheckpoint
         executor =
                 ThreadPoolExecutorFactory.createScheduledThreadPoolExecutor(
                         1, String.format("parallel-reader-checkpoint-executor-%s", subtaskId));
@@ -123,6 +125,7 @@ public void prepareCheckpoint() {
 
     public void virtualCheckpoint() {
         try {
+            // checkPoint
             int checkpointRetries = Math.max(1, CHECKPOINT_RETRIES);
             do {
                 checkpointRetries--;