database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](planner) mark join slot should always be nullable (#25433)

Browse Source
This commit is contained in:
starocean999
2023-10-17 19:14:13 +08:00
committed by GitHub
parent b74836050a
commit 9b1cdd3230
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/analysis/Analyzer.java
View File

@ -994,7 +994,10 @@ public class Analyzer {
newTblName == null ? "table list" : newTblName.toString());
}
Column col = d.getTable() == null ? new Column(colName, ScalarType.BOOLEAN) : d.getTable().getColumn(colName);
Column col = (d.getTable() == null)
? new Column(colName, ScalarType.BOOLEAN,
globalState.markTuples.get(d.getAlias()) != null)
: d.getTable().getColumn(colName);
if (col == null) {
ErrorReport.reportAnalysisException(ErrorCode.ERR_BAD_FIELD_ERROR, colName,
newTblName == null ? d.getTable().getName() : newTblName.toString());

2
fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java
View File

@ -529,7 +529,7 @@ public class StmtRewriter {
String slotName = stmt.getColumnAliasGenerator().getNextAlias();
markSlot.setType(ScalarType.BOOLEAN);
markSlot.setIsMaterialized(true);
markSlot.setIsNullable(false);
markSlot.setIsNullable(true);
markSlot.setColumn(new Column(slotName, ScalarType.BOOLEAN));
SlotRef markRef = new SlotRef(markSlot);
markRef.setTblName(new TableName(null, null, markTuple.getAlias()));