diff --git a/be/src/runtime/load_stream.cpp b/be/src/runtime/load_stream.cpp index 0a735184b0b483..bd083127ab1336 100644 --- a/be/src/runtime/load_stream.cpp +++ b/be/src/runtime/load_stream.cpp @@ -606,6 +606,9 @@ void LoadStream::_report_tablet_load_info(StreamId stream, int64_t index_id) { PLoadStreamResponse response; auto* tablet_load_infos = response.mutable_tablet_load_rowset_num_infos(); _collect_tablet_load_info_from_tablets(write_tablet_ids, tablet_load_infos); + if (tablet_load_infos->empty()) { + return; + } buf.append(response.SerializeAsString()); auto wst = _write_stream(stream, buf); if (!wst.ok()) {