This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 37f5a10f8cb [fix](Nereids) bind sink should use full base schema
(#25398)
37f5a10f8cb is described below
commit 37f5a10f8cbe0b158a78282ee24ae387c210ab6d
Author: morrySnow <[email protected]>
AuthorDate: Fri Oct 13 17:11:43 2023 +0800
[fix](Nereids) bind sink should use full base schema (#25398)
picked from master
PR: #25153
commit id: d34ab7accc2b70a570f57c4145d9c1a570642070
---
.../src/main/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 479490cb29f..3aba375e13e 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 class BindSink implements AnalysisRuleFactory {
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()));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
