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: