diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java index 2a6596aa9b86c1a..099500a856f38f1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java @@ -1963,7 +1963,9 @@ public TStreamLoadMultiTablePutResult streamLoadMultiTablePut(TStreamLoadPutRequ throw new MetaNotFoundException("table not found"); } olapTables = new ArrayList<>(tableNames.size()); - Map olapTableMap = tables.stream().map(OlapTable.class::cast) + Map olapTableMap = tables.stream(). + .filter(OlapTable.class::isInstance) + .map(OlapTable.class::cast) .collect(Collectors.toMap(OlapTable::getName, olapTable -> olapTable)); for (String tableName : tableNames) { if (null == olapTableMap.get(tableName)) {