(inlong) branch master updated: [INLONG-11681][Agent] Fix bug of duplicate file collection (#11682)

[wenweihuang]

This is an automated email from the ASF dual-hosted git repository.

wenweihuang 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 fd7190f7ad [INLONG-11681][Agent] Fix bug of duplicate file collection 
(#11682)
fd7190f7ad is described below

commit fd7190f7ad49d3f61e7db931ebe8b59d48cc2db7
Author: justinwwhuang <hww_jus...@163.com>
AuthorDate: Mon Jan 20 10:13:10 2025 +0800

    [INLONG-11681][Agent] Fix bug of duplicate file collection (#11682)
---
 .../src/main/java/org/apache/inlong/agent/store/InstanceStore.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java
 
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java
index 476d014e57..1ccf16ae44 100644
--- 
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java
+++ 
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java
@@ -72,7 +72,7 @@ public class InstanceStore {
      * @return list of task
      */
     public List<InstanceProfile> getInstances(String taskId) {
-        List<KeyValueEntity> result = 
this.store.findAll(getKeyByTaskId(taskId));
+        List<KeyValueEntity> result = 
this.store.findAll(getKeyByTaskId(taskId) + store.getSplitter());
         List<InstanceProfile> instanceList = new ArrayList<>();
         for (KeyValueEntity entity : result) {
             instanceList.add(entity.getAsInstanceProfile());