Skip to content

Commit

Permalink
'fix-bugs'
Browse files Browse the repository at this point in the history
  • Loading branch information
sohardforaname committed Aug 16, 2023
1 parent 0b8d8e9 commit a396324
Showing 1 changed file with 0 additions and 18 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -264,24 +264,6 @@ public void createPlanFragments(StatementBase statement, Analyzer analyzer, TQue

Collections.reverse(fragments);

// the nullable mode will be changed in create plan fragment, we should adjust the ones in querystmt's result
// exprs.
if (queryStmt instanceof SelectStmt) {
PlanFragment root = fragments.get(0);
List<SlotDescriptor> slots = analyzer.getDescTbl()
.getTupleDesc(root.getPlanRoot().getOutputTupleIds().get(0))
.getSlots();
// to exclude the cases that outputs contain an expression.
if (queryStmt.getResultExprs().size() == slots.size()) {
for (int i = 0; i < slots.size(); ++i) {
if (queryStmt.getResultExprs().get(i).getSrcSlotRef() != null) {
queryStmt.getResultExprs().get(i).getSrcSlotRef().getColumn()
.setIsAllowNull(slots.get(i).getIsNullable());
}
}
}
}

pushDownResultFileSink(analyzer);

pushOutColumnUniqueIdsToOlapScan(rootFragment, analyzer);
Expand Down

0 comments on commit a396324

Please sign in to comment.