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 7edfffd6d3 [INLONG-10749][Agent] Fix Instance store leak bug (#10750)
7edfffd6d3 is described below
commit 7edfffd6d3198d4e14557880c7c992123c4ea856
Author: justinwwhuang <[email protected]>
AuthorDate: Mon Aug 5 19:17:52 2024 +0800
[INLONG-10749][Agent] Fix Instance store leak bug (#10750)
---
.../src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java | 3 ---
1 file changed, 3 deletions(-)
diff --git
a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java
b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java
index 024a846e39..05aca28f28 100644
---
a/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java
+++
b/inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java
@@ -149,9 +149,6 @@ public class OffsetManager extends AbstractDaemon {
InstanceProfile instanceFromDb = iterator.next();
String taskId = instanceFromDb.getTaskId();
String instanceId = instanceFromDb.getInstanceId();
- if (instanceFromDb.getState() != InstanceStateEnum.FINISHED) {
- continue;
- }
TaskProfile taskFromDb = taskStore.getTask(taskId);
if (taskFromDb != null) {
if
(taskFromDb.getCycleUnit().compareToIgnoreCase(CycleUnitType.REAL_TIME) == 0) {
