healchow commented on code in PR #7989:
URL: https://github.com/apache/inlong/pull/7989#discussion_r1189464788


##########
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java:
##########
@@ -129,6 +129,8 @@ public void report(TaskRequest request) {
             throw new BusinessException("agent request or agent ip was empty, 
just return");
         }
 
+        preTimeoutTasks(request);

Review Comment:
   Can this method be made asynchronous, or can StreamSources be added to the 
queue, and other threads can be scheduled to rotate for processing to prevent 
this operation from taking too long or other problems, causing the report 
interface to respond to timeout or failure?
   
   这个方法能否做成异步的,或者将配置加入队列,由其他的线程定时去轮训处理,以防止这个操作耗时太久或出现其他问题,导致 report 接口响应超时或失败。



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to