diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp index 536a8cf3302e0f..55c14b9f9a57f8 100644 --- a/be/src/vec/sink/vtablet_sink.cpp +++ b/be/src/vec/sink/vtablet_sink.cpp @@ -1259,6 +1259,9 @@ Status VOlapTableSink::_single_partition_generate(RuntimeState* state, vectorize } break; } + if (partition == nullptr) { + return Status::OK(); + } for (int j = 0; j < partition->indexes.size(); ++j) { auto tid = partition->indexes[j].tablets[tablet_index]; auto it = _channels[j]->_channels_by_tablet.find(tid);