From 6997175f5bd02d6aaf210f43bc4431a800a60f92 Mon Sep 17 00:00:00 2001
From: chenhao7253886 <chenhao16@baidu.com>
Date: Tue, 27 Nov 2018 15:40:32 +0800
Subject: [PATCH] Fix cast error in StreamLoadScanNodeush

---
 .../java/org/apache/doris/planner/StreamLoadScanNode.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/fe/src/main/java/org/apache/doris/planner/StreamLoadScanNode.java b/fe/src/main/java/org/apache/doris/planner/StreamLoadScanNode.java
index 8d0a4c2a78fda0..e17a3fc0b52ae9 100644
--- a/fe/src/main/java/org/apache/doris/planner/StreamLoadScanNode.java
+++ b/fe/src/main/java/org/apache/doris/planner/StreamLoadScanNode.java
@@ -329,9 +329,11 @@ private void finalizeParams() throws UserException {
     }
 
     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;