From a8af81a417d59559ab20c72a3510e261099ba540 Mon Sep 17 00:00:00 2001 From: morningman Date: Mon, 1 Apr 2019 10:12:51 +0800 Subject: [PATCH] Fix bug that stream load use invalid file type --- fe/src/main/java/org/apache/doris/task/StreamLoadTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/src/main/java/org/apache/doris/task/StreamLoadTask.java b/fe/src/main/java/org/apache/doris/task/StreamLoadTask.java index d62bfb98b03902..39007cd71043ff 100644 --- a/fe/src/main/java/org/apache/doris/task/StreamLoadTask.java +++ b/fe/src/main/java/org/apache/doris/task/StreamLoadTask.java @@ -124,7 +124,7 @@ private void setOptionalFromTSLPutRequest(TStreamLoadPutRequest request) throws partitions = request.getPartitions(); } switch (request.getFileType()) { - case FILE_LOCAL: + case FILE_STREAM: path = request.getPath(); break; default: