Skip to content

Commit b66f685

Browse files
authored
Set remote requst's DagRequest flags field (#8606) (#8611)
close #8607
1 parent 27ead78 commit b66f685

File tree

2 files changed

+47
-0
lines changed

2 files changed

+47
-0
lines changed

dbms/src/Flash/Coprocessor/RemoteRequest.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,8 @@ RemoteRequest RemoteRequest::build(
8989
/// will be collected by CoprocessorBlockInputStream.
9090
/// Otherwise rows in execution summary of table scan will be double.
9191
dag_req.set_collect_execution_summaries(false);
92+
dag_req.set_flags(dag_context.getFlags());
93+
dag_req.set_sql_mode(dag_context.getSQLMode());
9294
const auto & original_dag_req = *dag_context.dag_request;
9395
if (original_dag_req.has_time_zone_name() && !original_dag_req.time_zone_name().empty())
9496
dag_req.set_time_zone_name(original_dag_req.time_zone_name());
Lines changed: 45 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
# Copyright 2023 PingCAP, Inc.
2+
#
3+
# Licensed under the Apache License, Version 2.0 (the "License");
4+
# you may not use this file except in compliance with the License.
5+
# You may obtain a copy of the License at
6+
#
7+
# http://www.apache.org/licenses/LICENSE-2.0
8+
#
9+
# Unless required by applicable law or agreed to in writing, software
10+
# distributed under the License is distributed on an "AS IS" BASIS,
11+
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
# See the License for the specific language governing permissions and
13+
# limitations under the License.
14+
15+
# Preparation.
16+
=> DBGInvoke __init_fail_point()
17+
18+
mysql> drop table if exists test.t
19+
mysql> create table test.t (a int);
20+
21+
mysql> insert into test.t values (123456789);
22+
23+
mysql> alter table test.t set tiflash replica 1;
24+
func> wait_table test t
25+
26+
mysql> set tidb_isolation_read_engines='tiflash'; set tidb_enforce_mpp=1; select * from test.t where cast(a as char(5)) = '12345';
27+
+-----------+
28+
| a |
29+
+-----------+
30+
| 123456789 |
31+
+-----------+
32+
33+
=> DBGInvoke __enable_fail_point(force_remote_read_for_batch_cop)
34+
35+
mysql> set tidb_isolation_read_engines='tiflash'; set tidb_enforce_mpp=1; select * from test.t where cast(a as char(5)) = '12345';
36+
+-----------+
37+
| a |
38+
+-----------+
39+
| 123456789 |
40+
+-----------+
41+
42+
=> DBGInvoke __disable_fail_point(force_remote_read_for_batch_cop)
43+
44+
# Clean up.
45+
mysql> drop table if exists test.t;

0 commit comments

Comments
 (0)