diff --git a/contrib/kvproto b/contrib/kvproto
index bb1dca91e3f..74c8557cdac 160000
--- a/contrib/kvproto
+++ b/contrib/kvproto
@@ -1 +1 @@
-Subproject commit bb1dca91e3f2a7a2f6960ed053e70d5e6af90ac6
+Subproject commit 74c8557cdac0e1e3e87bcee4ba23cfb4f8fcd930
diff --git a/dbms/src/Flash/Mpp/MPPTask.cpp b/dbms/src/Flash/Mpp/MPPTask.cpp
index 1b1fe18549a..070db41941c 100644
--- a/dbms/src/Flash/Mpp/MPPTask.cpp
+++ b/dbms/src/Flash/Mpp/MPPTask.cpp
@@ -533,6 +533,7 @@ void MPPTask::prepare(const mpp::DispatchTaskRequest & task_request)
     dag_context = std::make_unique<DAGContext>(dag_req, task_request.meta(), is_root_mpp_task);
     dag_context->log = log;
     dag_context->tables_regions_info = std::move(tables_regions_info);
+    dag_context->query_shard_infos = QueryShardInfos::create(task_request.table_shard_infos());
     dag_context->tidb_host = context->getClientInfo().current_address.toString();
 
     context->setDAGContext(dag_context.get());