diff --git a/contrib/client-c b/contrib/client-c index 1325209da01..0c834b9fe18 160000 --- a/contrib/client-c +++ b/contrib/client-c @@ -1 +1 @@ -Subproject commit 1325209da019f5d6e2a17b18a3b4e1f4a49f0852 +Subproject commit 0c834b9fe189841e078046b7b66d4960acc339fc diff --git a/dbms/src/Flash/Coprocessor/DAGQueryBlockInterpreter.cpp b/dbms/src/Flash/Coprocessor/DAGQueryBlockInterpreter.cpp index 035e832e3a7..4f8d445b1b8 100644 --- a/dbms/src/Flash/Coprocessor/DAGQueryBlockInterpreter.cpp +++ b/dbms/src/Flash/Coprocessor/DAGQueryBlockInterpreter.cpp @@ -1265,6 +1265,7 @@ void DAGQueryBlockInterpreter::executeRemoteQueryImpl(DAGPipeline & pipeline, dag_req.SerializeToString(&(req->data)); req->tp = pingcap::coprocessor::ReqType::DAG; req->start_ts = context.getSettingsRef().read_tso; + req->schema_version = context.getSettingsRef().schema_version; pingcap::kv::Cluster * cluster = context.getTMTContext().getKVCluster(); pingcap::kv::Backoffer bo(pingcap::kv::copBuildTaskMaxBackoff);