lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(monitor): 优化pulsar backlog读取的压力

Browse Source
This commit is contained in:
v-zhangjc9
2024-05-22 13:08:50 +08:00
parent 69f1f2207a
commit a4710845d7
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-monitor/src/main/java/com/lanyuanxiaoyao/service/monitor/metric/PulsarMetrics.java
View File

@@ -51,7 +51,7 @@ public class PulsarMetrics extends Metrics {
@Override @Override
void update() { void update() {
infoService.tableMetaList() infoService.tableMetaList()
.asParallel(ExecutorProvider.EXECUTORS, 2) .asParallel(ExecutorProvider.EXECUTORS_2, 1)
.reject(meta -> StrUtil.isBlank(meta.getPulsarAddress())) .reject(meta -> StrUtil.isBlank(meta.getPulsarAddress()))
.forEach(meta -> { .forEach(meta -> {
try { try {