From ae7b8ed8a2000ad875fb05290e44e622855a75b6 Mon Sep 17 00:00:00 2001 From: morrySnow Date: Fri, 13 Oct 2023 11:57:46 +0800 Subject: [PATCH] [fix](Nereids) bind sink should use full base schema picked from master PR: #25153 commit id: d34ab7accc2b70a570f57c4145d9c1a570642070 --- .../java/org/apache/doris/nereids/rules/analysis/BindSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java index 479490cb29f9f7..3aba375e13ec49 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java @@ -131,7 +131,7 @@ public List buildRules() { if (table.hasSequenceCol() && column.getName().equals(Column.SEQUENCE_COL) && table.getSequenceMapCol() != null) { - Column seqCol = table.getFullSchema().stream() + Column seqCol = table.getBaseSchema(true).stream() .filter(col -> col.getName().equals(table.getSequenceMapCol())) .findFirst().get(); columnToOutput.put(column.getName(), columnToOutput.get(seqCol.getName()));