From 66f8318114f02f9694b4337d971cdf7cd8146b0c Mon Sep 17 00:00:00 2001 From: ChangRui-Ryan Date: Wed, 18 Mar 2026 21:09:59 +0800 Subject: [PATCH] tici: support mpp join --- contrib/kvproto | 2 +- dbms/src/Flash/Mpp/MPPTask.cpp | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) 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(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());