[Bug](stream-load) fix stream load failed on table with rollup (#29665)
fix stream load failed on table with rollup
This commit is contained in:
@ -460,6 +460,9 @@ public class Load {
|
||||
Map<String, Expr> mvDefineExpr = Maps.newHashMap();
|
||||
for (Column column : tbl.getFullSchema()) {
|
||||
if (column.getDefineExpr() != null) {
|
||||
if (column.getDefineExpr().getType().isInvalid()) {
|
||||
column.getDefineExpr().setType(column.getType());
|
||||
}
|
||||
mvDefineExpr.put(column.getName(), column.getDefineExpr());
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user