Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
@924060929
924060929 committed Jun 19, 2024
1 parent cbfb692 commit 5c8c08a
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/AbstractUnassignedScanJob.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -90,13 +90,13 @@ protected List<AssignedJob> insideMachineParallelization(
// to process Aggregation parallel. We call it `share scan`. Backend will know this
// instances share the same ScanSource, and will not scan same data multiple times.
//
// +-------------------------------- same fragment in one host ------------------------------------+
// | instance1 instance2 instance3 instance4 |
// | \ \ / / |
// | |
// | OlapScanNode |
// |(share scan node, and local shuffle data to other local instance to parallel compute this data)|
// +-----------------------------------------------------------------------------------------------+
// +-------------------------------- same fragment in one host -------------------------------------+
// | instance1 instance2 instance3 instance4 |
// | \ \ / / |
// | |
// | OlapScanNode |
// |(share scan node, and local shuffle data to other local instances to parallel compute this data)|
// +------------------------------------------------------------------------------------------------+
ScanSource shareScanSource = instanceToScanRanges.get(0);
for (int i = 0; i < instanceNum; i++) {
// one scan range generate instanceNum instances,
Expand Down

0 comments on commit 5c8c08a

Please sign in to comment.