Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
Gabriel39 committed Nov 22, 2024
1 parent ba28f15 commit bda1873
Showing 1 changed file with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,6 @@ private void setForDefaultScanSource(
ScanNode scanNode = scanNodeIdToReplicaIds.getKey();
ScanRanges scanReplicas = scanNodeIdToReplicaIds.getValue();
instanceExecParam.perNodeScanRanges.put(scanNode.getId().asInt(), scanReplicas.params);
instanceExecParam.perNodeSharedScans.put(scanNode.getId().asInt(), isShareScan);
}
}

Expand All @@ -157,7 +156,6 @@ private void setForBucketScanSource(FInstanceExecParam instanceExecParam,
List<TScanRangeParams> scanBucketTablets = instanceExecParam.perNodeScanRanges.computeIfAbsent(
scanNode.getId().asInt(), id -> Lists.newArrayList());
scanBucketTablets.addAll(scanRanges.params);
instanceExecParam.perNodeSharedScans.put(scanNode.getId().asInt(), isShareScan);

if (scanNode instanceof OlapScanNode) {
OlapScanNode olapScanNode = (OlapScanNode) scanNode;
Expand Down

0 comments on commit bda1873

Please sign in to comment.