[INLONG-9125][Agent] Add offset manager

justinwwhuang · Oct 26, 2023 · d63f54c · d63f54c
1 parent d31c10b
commit d63f54c
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java
@@ -24,9 +24,8 @@
 import org.slf4j.LoggerFactory;
 
 /**
- * used to store task position to db, task position is stored as properties in JobProfile.
- * where key is task read file name and value is task sink position
- * note that this class is generated
+ * used to store instance offset to db
+ * where key is task id + read file name and value is instance offset
  */
 public class OffsetManager {