This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 6d5bc26c61 [INLONG-9716][Agent] Delete useless code when storing tasks
(#9717)
6d5bc26c61 is described below
commit 6d5bc26c610162e6e71a93ee4b20dbc3dea9993a
Author: justinwwhuang <[email protected]>
AuthorDate: Wed Feb 21 15:49:57 2024 +0800
[INLONG-9716][Agent] Delete useless code when storing tasks (#9717)
---
.../src/main/java/org/apache/inlong/agent/db/TaskProfileDb.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/TaskProfileDb.java
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/TaskProfileDb.java
index d37c3f9b10..02c616ff83 100755
---
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/TaskProfileDb.java
+++
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/TaskProfileDb.java
@@ -19,7 +19,6 @@ package org.apache.inlong.agent.db;
import org.apache.inlong.agent.conf.TaskProfile;
import org.apache.inlong.agent.constant.CommonConstants;
-import org.apache.inlong.agent.constant.TaskConstants;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -63,7 +62,7 @@ public class TaskProfileDb {
if (task.allRequiredKeyExist()) {
String keyName = getKeyByTaskId(task.getTaskId());
KeyValueEntity entity = new KeyValueEntity(keyName,
- task.toJsonStr(),
task.get(TaskConstants.FILE_DIR_FILTER_PATTERNS));
+ task.toJsonStr(), "");
db.put(entity);
}
}