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 476d014e570..1ccf16ae444 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 int getRunningInstanceCount() { * @return list of task */ public List getInstances(String taskId) { - List result = this.store.findAll(getKeyByTaskId(taskId)); + List result = this.store.findAll(getKeyByTaskId(taskId) + store.getSplitter()); List instanceList = new ArrayList<>(); for (KeyValueEntity entity : result) { instanceList.add(entity.getAsInstanceProfile());