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 the `preTimeoutTasks` 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?
这个 `preTimeoutTasks` 方法能否做成异步的，或者将配置加入队列，由其他的线程定时去轮训处理，以防止`preTimeoutTasks`
操作耗时太久或出现其他问题，导致 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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
