You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/01/25 11:16:48 UTC
[incubator-inlong] branch master updated: [INLONG-2336][Agent] fix the bug that the manager fetcher thread was shielded (#2337)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 7403c2c [INLONG-2336][Agent] fix the bug that the manager fetcher thread was shielded (#2337)
7403c2c is described below
commit 7403c2c63cacaaed5582599121d9fe777c71bb9c
Author: justinwwhuang <hw...@163.com>
AuthorDate: Tue Jan 25 19:16:44 2022 +0800
[INLONG-2336][Agent] fix the bug that the manager fetcher thread was shielded (#2337)
---
.../java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
index afd4f14..29355d7 100755
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
+++ b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java
@@ -471,9 +471,11 @@ public class ManagerFetcher extends AbstractDaemon implements ProfileFetcher {
DEFAULT_AGENT_FETCHER_INTERVAL);
TimeUnit.SECONDS.sleep(AgentUtils.getRandomBySeed(configSleepTime));
// fetch commands from manager
- //fetchCommand();
+ fetchCommand();
+
// fetch manager list from vip
- //fetchTdmList(false, 0);
+ fetchTdmList(false, 0);
+
// fetch db collector task from manager
fetchDbCollectTask();
} catch (Exception ex) {