[Exec](RF) Support merge remote rf local first (#31067)

This commit is contained in:
HappenLee
2024-02-21 22:38:33 +08:00
committed by yiguolei
parent 8a496bf554
commit c56cb0ac3e
24 changed files with 248 additions and 174 deletions

View File

@ -2150,7 +2150,8 @@ public class Coordinator implements CoordInterface {
}
for (RuntimeFilterId rid : fragment.getBuilderRuntimeFilterIds()) {
ridToBuilderNum.merge(rid, params.instanceExecParams.size(), Integer::sum);
ridToBuilderNum.merge(rid,
(int) params.instanceExecParams.stream().map(ins -> ins.host).distinct().count(), Integer::sum);
}
}
// Use the uppermost fragment as a merged node, the uppermost fragment has one and only one instance