[fix](load) fix single replica load with auto partition

This commit is contained in:
zclllyybb
2024-01-03 11:53:09 +08:00
committed by GitHub
parent 5eb38301dd
commit c0db8533af
2 changed files with 4 additions and 0 deletions

View File

@ -527,6 +527,7 @@ public class OlapTableSink extends DataSink {
// for partition by function expr, there is no any partition firstly, But this is required in thrift struct.
if (partitionIds.isEmpty()) {
locationParam.setTablets(new ArrayList<TTabletLocation>());
slaveLocationParam.setTablets(new ArrayList<TTabletLocation>());
}
// check if disk capacity reach limit
// this is for load process, so use high water mark to check