From d63f54cb71797783b53b4e92086843791b406379 Mon Sep 17 00:00:00 2001
From: wenweihuang <hww_justin@163.com>
Date: Thu, 26 Oct 2023 20:20:42 +0800
Subject: [PATCH] [INLONG-9125][Agent] Add offset manager

---
 .../org/apache/inlong/agent/core/task/OffsetManager.java     | 5 ++---
 1 file changed, 2 insertions(+), 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
index 25c1cd77f92..0c4ca513ce3 100644
--- 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 {