vernedeng commented on code in PR #4917:
URL: https://github.com/apache/inlong/pull/4917#discussion_r917593349
##########
inlong-manager/manager-dao/src/main/resources/mappers/StreamSinkEntityMapper.xml:
##########
@@ -480,5 +480,15 @@
is_deleted = 0
</where>
</select>
+ <select id="selectAllStreams"
+
resultType="org.apache.inlong.manager.common.pojo.sortstandalone.SortSourceStreamInfo">
+ select inlong_cluster_name as sortClusterName,
+ sort_task_name,
+ inlong_group_id as groupId
+ from stream_sink
+ <where>
Review Comment:
It will reload all configs each 10 seconds and cached them in memory, the
overhead is acceptable.
--
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]
