tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix: Preserve integer width in ColumnFilterConverter 

Co-authored-by: huanmingwong <huanmingwong@gmail.com>
This commit is contained in:
Cursor Agent 2025-09-29 02:15:07 +00:00
parent d597f92555
commit 37f81dbc18
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
fe/fe-core/src/main/java/com/starrocks/sql/optimizer/operator/ColumnFilterConverter.java
View File

@ -123,8 +123,20 @@ public class ColumnFilterConverter {
Expr firstExpr = node.getChild(0);
if (firstExpr instanceof SlotRef slotRef) {
if (columnRef.getName().equals(slotRef.getColumnName())) {
node.setChild(0, new IntLiteral(constant.getBigint()));
return true;
try {
// Preserve the original column's integer width to match the analyzed
// function signature in partition expressions and avoid FE assertions.
if (columnRef.getType().equals(Type.INT)) {
node.setChild(0, new IntLiteral(constant.getInt(), Type.INT));
} else {
// Default to BIGINT for other integer widths (e.g. BIGINT)
node.setChild(0, new IntLiteral(constant.getBigint(), Type.BIGINT));
}
return true;
} catch (Exception e) {
// If the constant doesn't fit the target type, skip rewriting.
return false;
}
}
}
}