diff --git a/dbms/src/Flash/Coprocessor/DAGStorageInterpreter.cpp b/dbms/src/Flash/Coprocessor/DAGStorageInterpreter.cpp index b00072aad31..d08760d516e 100644 --- a/dbms/src/Flash/Coprocessor/DAGStorageInterpreter.cpp +++ b/dbms/src/Flash/Coprocessor/DAGStorageInterpreter.cpp @@ -1015,6 +1015,7 @@ void DAGStorageInterpreter::buildLocalStreams(DAGPipeline & pipeline, size_t max size_t total_local_region_num = mvcc_query_info->regions_query_info.size(); if (total_local_region_num == 0) return; + mvcc_query_info->scan_context->total_local_region_num = total_local_region_num; const auto table_query_infos = generateSelectQueryInfos(); bool has_multiple_partitions = table_query_infos.size() > 1; // MultiPartitionStreamPool will be disabled in no partition mode or single-partition case @@ -1075,6 +1076,7 @@ void DAGStorageInterpreter::buildLocalExec( size_t total_local_region_num = mvcc_query_info->regions_query_info.size(); if (total_local_region_num == 0) return; + mvcc_query_info->scan_context->total_local_region_num = total_local_region_num; const auto table_query_infos = generateSelectQueryInfos(); auto disaggregated_snap = std::make_shared();