diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java index 29d8a1ddf8f7ab..179f811854e755 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java @@ -626,8 +626,8 @@ private void checkEndpoint(String endpoint) throws UserException { } public void checkS3Param() throws UserException { - if (brokerDesc.getFileType() != null && brokerDesc.getFileType().equals(TFileType.FILE_S3)) { - + if (brokerDesc.getFileType() != null && brokerDesc.getFileType().equals(TFileType.FILE_S3) + && brokerDesc.getStorageProperties() instanceof ObjectStorageProperties) { ObjectStorageProperties storageProperties = (ObjectStorageProperties) brokerDesc.getStorageProperties(); String endpoint = storageProperties.getEndpoint(); checkEndpoint(endpoint);