[incubator-inlong] branch master updated: [INLONG-2336][Agent] fix the bug that the manager fetcher thread was shielded (#2337)

[healchow]

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 <hww_jus...@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) {