[INLONG-11681][Agent] Fix bug of duplicate file collection (#11682)

apache · Jan 20, 2025 · fd7190f · fd7190f
1 parent d66bd13
commit fd7190f
Showing 1 changed file with 1 addition and 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
@@ -72,7 +72,7 @@ public int getRunningInstanceCount() {
      * @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());