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);
         }
     }

Reply via email to