hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Fix master case

Browse Source
This commit is contained in:
qianchanger
2023-05-04 12:19:40 +00:00
committed by ob-robot
parent f72319a1ed
commit 03ed5b7544
2 changed files with 29 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/engine/px/p2p_datahub/ob_runtime_filter_msg.cpp
View File

@ -887,9 +887,6 @@ int ObRFRangeFilterMsg::dynamic_copy_cell(const ObDatum &src, ObDatum &target, i
int64_t need_size = src.len_; int64_t need_size = src.len_;
if (src.is_null()) { if (src.is_null()) {
target.null_ = 1; target.null_ = 1;
} else if (OB_UNLIKELY(0 == src.len_)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected null src datum", K(ret));
} else { } else {
if (need_size > cell_size) { if (need_size > cell_size) {
need_size = need_size * 2; need_size = need_size * 2;

49
tools/deploy/mysql_test/test_suite/px/r/mysql/dml_use_px.result
View File

@ -342,12 +342,12 @@ Query Plan
|1 |└─PX COORDINATOR | | |1 |└─PX COORDINATOR | |
|2 | └─EXCHANGE OUT DISTR |:EX10001| |2 | └─EXCHANGE OUT DISTR |:EX10001|
|3 | └─SHARED HASH JOIN | | |3 | └─SHARED HASH JOIN | |
|4 | ├─PART JOIN FILTER CREATE |:BF0000 | |4 | ├─PART JOIN FILTER CREATE |:RF0000 |
|5 | │ └─EXCHANGE IN DISTR | | |5 | │ └─EXCHANGE IN DISTR | |
|6 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000| |6 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000|
|7 | │ └─PX BLOCK ITERATOR | | |7 | │ └─PX BLOCK ITERATOR | |
|8 | │ └─TABLE RANGE SCAN |t_p4 | |8 | │ └─TABLE RANGE SCAN |t_p4 |
|9 | └─PX BLOCK HASH JOIN-FILTER |:BF0000 | |9 | └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|10| └─TABLE RANGE SCAN |t_p | |10| └─TABLE RANGE SCAN |t_p |
====================================================== ======================================================
Outputs & filters: Outputs & filters:
@ -360,6 +360,7 @@ Outputs & filters:
3 - output([t_p.c1], [t_p.c2], [t_p.c3]), filter(nil), rowset=256 3 - output([t_p.c1], [t_p.c2], [t_p.c3]), filter(nil), rowset=256
equal_conds([t_p.c1 = t_p4.c1]), other_conds(nil) equal_conds([t_p.c1 = t_p4.c1]), other_conds(nil)
4 - output([t_p4.c1]), filter(nil), rowset=256 4 - output([t_p4.c1]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_p4.c1]
5 - output([t_p4.c1]), filter(nil), rowset=256 5 - output([t_p4.c1]), filter(nil), rowset=256
6 - output([t_p4.c1]), filter(nil), rowset=256 6 - output([t_p4.c1]), filter(nil), rowset=256
dop=10 dop=10
@ -398,12 +399,12 @@ Query Plan
|1 |└─PX COORDINATOR | | |1 |└─PX COORDINATOR | |
|2 | └─EXCHANGE OUT DISTR |:EX10001| |2 | └─EXCHANGE OUT DISTR |:EX10001|
|3 | └─SHARED HASH JOIN | | |3 | └─SHARED HASH JOIN | |
|4 | ├─PART JOIN FILTER CREATE |:BF0000 | |4 | ├─PART JOIN FILTER CREATE |:RF0000 |
|5 | │ └─EXCHANGE IN DISTR | | |5 | │ └─EXCHANGE IN DISTR | |
|6 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000| |6 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000|
|7 | │ └─PX BLOCK ITERATOR | | |7 | │ └─PX BLOCK ITERATOR | |
|8 | │ └─TABLE FULL SCAN |t_p4 | |8 | │ └─TABLE FULL SCAN |t_p4 |
|9 | └─PX BLOCK HASH JOIN-FILTER |:BF0000 | |9 | └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|10| └─TABLE RANGE SCAN |t_p | |10| └─TABLE RANGE SCAN |t_p |
====================================================== ======================================================
Outputs & filters: Outputs & filters:
@ -416,6 +417,7 @@ Outputs & filters:
3 - output([t_p.c1], [t_p.c2], [t_p.c3]), filter(nil), rowset=256 3 - output([t_p.c1], [t_p.c2], [t_p.c3]), filter(nil), rowset=256
equal_conds([t_p.c1 = t_p4.c2]), other_conds(nil) equal_conds([t_p.c1 = t_p4.c2]), other_conds(nil)
4 - output([t_p4.c2]), filter(nil), rowset=256 4 - output([t_p4.c2]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_p4.c2]
5 - output([t_p4.c2]), filter(nil), rowset=256 5 - output([t_p4.c2]), filter(nil), rowset=256
6 - output([t_p4.c2]), filter(nil), rowset=256 6 - output([t_p4.c2]), filter(nil), rowset=256
dop=10 dop=10
@ -439,12 +441,12 @@ Query Plan
|1 |└─PX COORDINATOR | | |1 |└─PX COORDINATOR | |
|2 | └─EXCHANGE OUT DISTR |:EX10001| |2 | └─EXCHANGE OUT DISTR |:EX10001|
|3 | └─SHARED HASH JOIN | | |3 | └─SHARED HASH JOIN | |
|4 | ├─PART JOIN FILTER CREATE |:BF0000 | |4 | ├─PART JOIN FILTER CREATE |:RF0000 |
|5 | │ └─EXCHANGE IN DISTR | | |5 | │ └─EXCHANGE IN DISTR | |
|6 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000| |6 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000|
|7 | │ └─PX BLOCK ITERATOR | | |7 | │ └─PX BLOCK ITERATOR | |
|8 | │ └─TABLE FULL SCAN |t_p4 | |8 | │ └─TABLE FULL SCAN |t_p4 |
|9 | └─PX BLOCK HASH JOIN-FILTER |:BF0000 | |9 | └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|10| └─TABLE RANGE SCAN |t_p | |10| └─TABLE RANGE SCAN |t_p |
====================================================== ======================================================
Outputs & filters: Outputs & filters:
@ -457,6 +459,7 @@ Outputs & filters:
3 - output([t_p.c1], [t_p.c2], [t_p.c3]), filter(nil), rowset=256 3 - output([t_p.c1], [t_p.c2], [t_p.c3]), filter(nil), rowset=256
equal_conds([t_p.c1 = t_p4.c2]), other_conds(nil) equal_conds([t_p.c1 = t_p4.c2]), other_conds(nil)
4 - output([t_p4.c2]), filter(nil), rowset=256 4 - output([t_p4.c2]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_p4.c2]
5 - output([t_p4.c2]), filter(nil), rowset=256 5 - output([t_p4.c2]), filter(nil), rowset=256
6 - output([t_p4.c2]), filter(nil), rowset=256 6 - output([t_p4.c2]), filter(nil), rowset=256
dop=10 dop=10
@ -630,12 +633,13 @@ Query Plan
|1 |└─PX COORDINATOR | | |1 |└─PX COORDINATOR | |
|2 | └─EXCHANGE OUT DISTR |:EX10001| |2 | └─EXCHANGE OUT DISTR |:EX10001|
|3 | └─HASH JOIN | | |3 | └─HASH JOIN | |
|4 | ├─PX BLOCK ITERATOR | | |4 | ├─PART JOIN FILTER CREATE |:RF0000 |
|5 | │ └─TABLE FULL SCAN |t_s | |5 | │ └─PX BLOCK ITERATOR | |
|6 | └─EXCHANGE IN DISTR | | |6 | │ └─TABLE FULL SCAN |t_s |
|7 | └─EXCHANGE OUT DISTR (BROADCAST)|:EX10000| |7 | └─EXCHANGE IN DISTR | |
|8 | └─PX BLOCK ITERATOR | | |8 | └─EXCHANGE OUT DISTR (BROADCAST)|:EX10000|
|9 | └─TABLE FULL SCAN |t_p | |9 | └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|10| └─TABLE FULL SCAN |t_p |
====================================================== ======================================================
Outputs & filters: Outputs & filters:
------------------------------------- -------------------------------------
@ -647,15 +651,17 @@ Outputs & filters:
3 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256 3 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256
equal_conds([t_p.c1 = t_s.c1]), other_conds(nil) equal_conds([t_p.c1 = t_s.c1]), other_conds(nil)
4 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256 4 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_s.c1]
5 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256 5 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256
6 - output([t_s.c1], [t_s.c2], [t_s.c3]), filter(nil), rowset=256
access([t_s.c1], [t_s.c2], [t_s.c3]), partitions(p0) access([t_s.c1], [t_s.c2], [t_s.c3]), partitions(p0)
is_index_back=false, is_global_index=false, is_index_back=false, is_global_index=false,
range_key([t_s.c1]), range(MIN ; MAX)always true range_key([t_s.c1]), range(MIN ; MAX)always true
6 - output([t_p.c1]), filter(nil), rowset=256
7 - output([t_p.c1]), filter(nil), rowset=256 7 - output([t_p.c1]), filter(nil), rowset=256
dop=10
8 - output([t_p.c1]), filter(nil), rowset=256 8 - output([t_p.c1]), filter(nil), rowset=256
dop=10
9 - output([t_p.c1]), filter(nil), rowset=256 9 - output([t_p.c1]), filter(nil), rowset=256
10 - output([t_p.c1], [PARTITION_ID]), filter(nil), rowset=256
access([t_p.c1]), partitions(p[0-3]) access([t_p.c1]), partitions(p[0-3])
is_index_back=false, is_global_index=false, is_index_back=false, is_global_index=false,
range_key([t_p.c1]), range(MIN ; MAX)always true range_key([t_p.c1]), range(MIN ; MAX)always true
@ -1910,12 +1916,12 @@ Query Plan
|2 | └─EXCHANGE OUT DISTR |:EX10001 | |2 | └─EXCHANGE OUT DISTR |:EX10001 |
|3 | └─SUBPLAN SCAN |ANONYMOUS_VIEW1| |3 | └─SUBPLAN SCAN |ANONYMOUS_VIEW1|
|4 | └─SHARED HASH JOIN | | |4 | └─SHARED HASH JOIN | |
|5 | ├─PART JOIN FILTER CREATE |:BF0000 | |5 | ├─PART JOIN FILTER CREATE |:RF0000 |
|6 | │ └─EXCHANGE IN DISTR | | |6 | │ └─EXCHANGE IN DISTR | |
|7 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000 | |7 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000 |
|8 | │ └─PX BLOCK ITERATOR | | |8 | │ └─PX BLOCK ITERATOR | |
|9 | │ └─TABLE FULL SCAN |t_temp_p5 | |9 | │ └─TABLE FULL SCAN |t_temp_p5 |
|10| └─PX BLOCK HASH JOIN-FILTER |:BF0000 | |10| └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|11| └─TABLE FULL SCAN |t_temp_p | |11| └─TABLE FULL SCAN |t_temp_p |
=============================================================== ===============================================================
Outputs & filters: Outputs & filters:
@ -1932,6 +1938,7 @@ Outputs & filters:
4 - output([t_temp_p.c1], [t_temp_p.c2], [t_temp_p.c3]), filter(nil), rowset=256 4 - output([t_temp_p.c1], [t_temp_p.c2], [t_temp_p.c3]), filter(nil), rowset=256
equal_conds([t_temp_p.c1 = t_temp_p5.c1]), other_conds(nil) equal_conds([t_temp_p.c1 = t_temp_p5.c1]), other_conds(nil)
5 - output([t_temp_p5.c1]), filter(nil), rowset=256 5 - output([t_temp_p5.c1]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_temp_p5.c1]
6 - output([t_temp_p5.c1]), filter(nil), rowset=256 6 - output([t_temp_p5.c1]), filter(nil), rowset=256
7 - output([t_temp_p5.c1]), filter(nil), rowset=256 7 - output([t_temp_p5.c1]), filter(nil), rowset=256
dop=10 dop=10
@ -1955,12 +1962,12 @@ Query Plan
|2 | └─EXCHANGE OUT DISTR |:EX10001 | |2 | └─EXCHANGE OUT DISTR |:EX10001 |
|3 | └─SUBPLAN SCAN |ANONYMOUS_VIEW1| |3 | └─SUBPLAN SCAN |ANONYMOUS_VIEW1|
|4 | └─SHARED HASH JOIN | | |4 | └─SHARED HASH JOIN | |
|5 | ├─PART JOIN FILTER CREATE |:BF0000 | |5 | ├─PART JOIN FILTER CREATE |:RF0000 |
|6 | │ └─EXCHANGE IN DISTR | | |6 | │ └─EXCHANGE IN DISTR | |
|7 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000 | |7 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000 |
|8 | │ └─PX BLOCK ITERATOR | | |8 | │ └─PX BLOCK ITERATOR | |
|9 | │ └─TABLE FULL SCAN |t_temp_p5 | |9 | │ └─TABLE FULL SCAN |t_temp_p5 |
|10| └─PX BLOCK HASH JOIN-FILTER |:BF0000 | |10| └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|11| └─TABLE FULL SCAN |t_temp_p | |11| └─TABLE FULL SCAN |t_temp_p |
=============================================================== ===============================================================
Outputs & filters: Outputs & filters:
@ -1977,6 +1984,7 @@ Outputs & filters:
4 - output([t_temp_p.c1], [t_temp_p.c2], [t_temp_p.c3]), filter(nil), rowset=256 4 - output([t_temp_p.c1], [t_temp_p.c2], [t_temp_p.c3]), filter(nil), rowset=256
equal_conds([t_temp_p.c1 = t_temp_p5.c1]), other_conds(nil) equal_conds([t_temp_p.c1 = t_temp_p5.c1]), other_conds(nil)
5 - output([t_temp_p5.c1]), filter(nil), rowset=256 5 - output([t_temp_p5.c1]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_temp_p5.c1]
6 - output([t_temp_p5.c1]), filter(nil), rowset=256 6 - output([t_temp_p5.c1]), filter(nil), rowset=256
7 - output([t_temp_p5.c1]), filter(nil), rowset=256 7 - output([t_temp_p5.c1]), filter(nil), rowset=256
dop=10 dop=10
@ -2074,12 +2082,12 @@ Query Plan
|2 | └─EXCHANGE OUT DISTR |:EX10001 | |2 | └─EXCHANGE OUT DISTR |:EX10001 |
|3 | └─SUBPLAN SCAN |ANONYMOUS_VIEW1| |3 | └─SUBPLAN SCAN |ANONYMOUS_VIEW1|
|4 | └─SHARED HASH JOIN | | |4 | └─SHARED HASH JOIN | |
|5 | ├─PART JOIN FILTER CREATE |:BF0000 | |5 | ├─PART JOIN FILTER CREATE |:RF0000 |
|6 | │ └─EXCHANGE IN DISTR | | |6 | │ └─EXCHANGE IN DISTR | |
|7 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000 | |7 | │ └─EXCHANGE OUT DISTR (BC2HOST)|:EX10000 |
|8 | │ └─PX BLOCK ITERATOR | | |8 | │ └─PX BLOCK ITERATOR | |
|9 | │ └─TABLE FULL SCAN |t_temp_p4 | |9 | │ └─TABLE FULL SCAN |t_temp_p4 |
|10| └─PX BLOCK HASH JOIN-FILTER |:BF0000 | |10| └─PX BLOCK HASH JOIN-FILTER |:RF0000 |
|11| └─TABLE FULL SCAN |t_temp_p | |11| └─TABLE FULL SCAN |t_temp_p |
=============================================================== ===============================================================
Outputs & filters: Outputs & filters:
@ -2096,6 +2104,7 @@ Outputs & filters:
4 - output([t_temp_p.c1], [t_temp_p.c2], [t_temp_p.c3]), filter(nil), rowset=256 4 - output([t_temp_p.c1], [t_temp_p.c2], [t_temp_p.c3]), filter(nil), rowset=256
equal_conds([t_temp_p.c1 = t_temp_p4.c1]), other_conds(nil) equal_conds([t_temp_p.c1 = t_temp_p4.c1]), other_conds(nil)
5 - output([t_temp_p4.c1]), filter(nil), rowset=256 5 - output([t_temp_p4.c1]), filter(nil), rowset=256
RF_TYPE(bloom), RF_EXPR[t_temp_p4.c1]
6 - output([t_temp_p4.c1]), filter(nil), rowset=256 6 - output([t_temp_p4.c1]), filter(nil), rowset=256
7 - output([t_temp_p4.c1]), filter(nil), rowset=256 7 - output([t_temp_p4.c1]), filter(nil), rowset=256
dop=10 dop=10