Skip to content

tici: support mpp join #10753

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ChangRui-Ryan wants to merge 1 commit into
base: feature/fts
Choose a base branch
from
+2 −1
Open

tici: support mpp join #10753

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion contrib/kvproto
Open in desktop
Submodule kvproto updated 67 files
+7 −0 .editorconfig
+6 −0 Makefile
+10 −0 README.md
+101 −101 include/eraftpb.proto
+33 −33 include/rustproto.proto
+304 −304 pkg/brpb/brpb.pb.go
+92 −92 pkg/cdcpb/cdcpb.pb.go
+3 −3 pkg/configpb/configpb.pb.go
+442 −94 pkg/coprocessor/coprocessor.pb.go
+145 −146 pkg/debugpb/debugpb.pb.go
+5 −5 pkg/disaggregated/disaggregated.pb.go
+9 −9 pkg/disk_usage/disk_usage.pb.go
+46 −46 pkg/enginepb/enginepb.pb.go
+82 −82 pkg/errorpb/errorpb.pb.go
+55 −55 pkg/import_kvpb/import_kvpb.pb.go
+244 −155 pkg/import_sstpb/import_sstpb.pb.go
+40 −39 pkg/keyspacepb/keyspacepb.pb.go
+1,466 −544 pkg/kvrpcpb/kvrpcpb.pb.go
+232 −60 pkg/mpp/mpp.pb.go
+873 −587 pkg/pdpb/pdpb.pb.go
+172 −172 pkg/raft_cmdpb/raft_cmdpb.pb.go
+144 −144 pkg/raft_serverpb/raft_serverpb.pb.go
+184 −124 pkg/resource_manager/resource_manager.pb.go
+21 −21 pkg/routerpb/routerpb.pb.go
+94 −94 pkg/schedulingpb/schedulingpb.pb.go
+250 −177 pkg/tikvpb/tikvpb.pb.go
+59 −59 pkg/tsopb/tsopb.pb.go
+23 −25 proto/autoid.proto
+730 −735 proto/brpb.proto
+135 −137 proto/cdcpb.proto
+77 −81 proto/configpb.proto
+133 −114 proto/coprocessor.proto
+46 −47 proto/deadlock.proto
+179 −191 proto/debugpb.proto
+53 −53 proto/diagnosticspb.proto
+95 −97 proto/disaggregated.proto
+9 −10 proto/disk_usage.proto
+95 −97 proto/encryptionpb.proto
+47 −48 proto/enginepb.proto
+108 −111 proto/errorpb.proto
+5 −6 proto/gcpb.proto
+74 −83 proto/import_kvpb.proto
+324 −327 proto/import_sstpb.proto
+12 −14 proto/keyspacepb.proto
+1,187 −1,155 proto/kvrpcpb.proto
+26 −29 proto/logbackuppb.proto
+100 −102 proto/meta_storagepb.proto
+101 −103 proto/metapb.proto
+57 −56 proto/mpp.proto
+809 −801 proto/pdpb.proto
+215 −218 proto/raft_cmdpb.proto
+207 −209 proto/raft_serverpb.proto
+42 −42 proto/recoverdatapb.proto
+40 −40 proto/replication_modepb.proto
+52 −48 proto/resource_manager.proto
+27 −29 proto/resource_usage_agent.proto
+13 −15 proto/routerpb.proto
+138 −140 proto/schedulingpb.proto
+5 −12 proto/tici.proto
+261 −254 proto/tikvpb.proto
+32 −33 proto/tracepb.proto
+73 −75 proto/tsopb.proto
+11 −1 scripts/check.sh
+207 −3 scripts/common.sh
+4 −5 scripts/generate_cpp.sh
+706 −512 scripts/proto.lock
+139 −0 scripts/proto_format.sh
1 change: 1 addition & 0 deletions dbms/src/Flash/Mpp/MPPTask.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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());
Expand Down