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

Fix cast error in StreamLoadScanNodeush (#356)

Browse Source
This commit is contained in:
chenhao
2018-11-27 16:03:33 +08:00
committed by ZHAO Chun
parent b2d89dfee9
commit cfefa71daa
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/src/main/java/org/apache/doris/planner/StreamLoadScanNode.java
View File

@ -329,9 +329,11 @@ public class StreamLoadScanNode extends ScanNode {
}
private Expr castToSlot(SlotDescriptor slotDesc, Expr expr) throws UserException {
if (slotDesc.getType().isNull()) {
return expr;
}
PrimitiveType dstType = slotDesc.getType().getPrimitiveType();
PrimitiveType srcType = expr.getType().getPrimitiveType();
if (dstType.isStringType()) {
if (srcType.isStringType()) {
return expr;