yiguolei commented on code in PR #48187:
URL: https://github.com/apache/doris/pull/48187#discussion_r1965710529
##########
fe/fe-core/src/main/java/org/apache/doris/catalog/OlapTable.java:
##########
@@ -3096,19 +3097,31 @@ public TFetchOption generateTwoPhaseReadOption(long
selectedIndexId) {
fetchOption.setFetchRowStore(useStoreRow);
fetchOption.setUseTwoPhaseFetch(true);
- // get backend by tag
- Set<Tag> tagSet = new HashSet<>();
ConnectContext context = ConnectContext.get();
- if (context != null) {
- tagSet = context.getResourceTags();
+ if (context == null) {
+ context = new ConnectContext();
+ context.setThreadLocalInfo();
}
BeSelectionPolicy policy = new BeSelectionPolicy.Builder()
.needQueryAvailable()
.setRequireAliveBe()
- .addTags(tagSet)
.build();
+
TPaloNodesInfo nodesInfo = new TPaloNodesInfo();
- for (Backend backend :
Env.getCurrentSystemInfo().getBackendsByPolicy(policy)) {
+ ComputeGroup computeGroup = null;
+ if (Config.isCloudMode()) {
+ try {
+ computeGroup = Env.getCurrentEnv().getComputeGroupMgr()
+ .getComputeGroup(context.getComputeGroup());
+ } catch (ComputeGroupException e) {
+ throw new RuntimeException(e);
+ }
+ } else {
+ computeGroup = Env.getCurrentEnv().getComputeGroupMgr()
+ .getComputeGroup(context.getComputeGroupSet());
Review Comment:
不论cloud 还是非cloud，都是用compute set 不行吗？只是cloud 里，这个值永远元素只有一个，非cloud 可能有多个元素？
--
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...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
