This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 6789f5bc80d [fix](null safe equal join) fix coredump if both sides of
the conjunct is not nullable #36263 (#37073)
6789f5bc80d is described below
commit 6789f5bc80db8742efbf54ac2a5562325914ff91
Author: TengJianPing <18241664+jackte...@users.noreply.github.com>
AuthorDate: Tue Jul 2 11:01:55 2024 +0800
[fix](null safe equal join) fix coredump if both sides of the conjunct is
not nullable #36263 (#37073)
---
be/src/pipeline/exec/hashjoin_build_sink.cpp | 10 +-
be/src/pipeline/exec/hashjoin_probe_operator.cpp | 8 +-
.../data/query_p0/join/rqg/rqg12257/rqg12257.out | 5 +
.../query_p0/join/rqg/rqg12257/rqg12257.groovy | 341 +++++++++++++++++++++
4 files changed, 360 insertions(+), 4 deletions(-)
diff --git a/be/src/pipeline/exec/hashjoin_build_sink.cpp
b/be/src/pipeline/exec/hashjoin_build_sink.cpp
index 56480096e3d..ccfd934af99 100644
--- a/be/src/pipeline/exec/hashjoin_build_sink.cpp
+++ b/be/src/pipeline/exec/hashjoin_build_sink.cpp
@@ -486,8 +486,14 @@ Status HashJoinBuildSinkOperatorX::init(const TPlanNode&
tnode, RuntimeState* st
const auto vexpr = _build_expr_ctxs.back()->root();
/// null safe equal means null = null is true, the operator in SQL
should be: <=>.
- const bool is_null_safe_equal = eq_join_conjunct.__isset.opcode &&
- eq_join_conjunct.opcode ==
TExprOpcode::EQ_FOR_NULL;
+ const bool is_null_safe_equal =
+ eq_join_conjunct.__isset.opcode &&
+ (eq_join_conjunct.opcode == TExprOpcode::EQ_FOR_NULL) &&
+ // For a null safe equal join, FE may generate a plan that
+ // both sides of the conjuct are not nullable, we just treat it
+ // as a normal equal join conjunct.
+ (eq_join_conjunct.right.nodes[0].is_nullable ||
+ eq_join_conjunct.left.nodes[0].is_nullable);
const bool should_convert_to_nullable = is_null_safe_equal &&
!eq_join_conjunct.right.nodes[0].is_nullable &&
diff --git a/be/src/pipeline/exec/hashjoin_probe_operator.cpp
b/be/src/pipeline/exec/hashjoin_probe_operator.cpp
index 00cf6a65eb0..002a79f2db2 100644
--- a/be/src/pipeline/exec/hashjoin_probe_operator.cpp
+++ b/be/src/pipeline/exec/hashjoin_probe_operator.cpp
@@ -540,13 +540,17 @@ Status HashJoinProbeOperatorX::init(const TPlanNode&
tnode, RuntimeState* state)
RETURN_IF_ERROR(vectorized::VExpr::create_expr_tree(eq_join_conjunct.left,
ctx));
_probe_expr_ctxs.push_back(ctx);
bool null_aware = eq_join_conjunct.__isset.opcode &&
- eq_join_conjunct.opcode == TExprOpcode::EQ_FOR_NULL;
+ eq_join_conjunct.opcode == TExprOpcode::EQ_FOR_NULL
&&
+ (eq_join_conjunct.right.nodes[0].is_nullable ||
+ eq_join_conjunct.left.nodes[0].is_nullable);
probe_not_ignore_null[conjuncts_index] =
null_aware ||
(_probe_expr_ctxs.back()->root()->is_nullable() &&
probe_dispose_null);
conjuncts_index++;
const bool is_null_safe_equal = eq_join_conjunct.__isset.opcode &&
- eq_join_conjunct.opcode ==
TExprOpcode::EQ_FOR_NULL;
+ (eq_join_conjunct.opcode ==
TExprOpcode::EQ_FOR_NULL) &&
+
(eq_join_conjunct.right.nodes[0].is_nullable ||
+
eq_join_conjunct.left.nodes[0].is_nullable);
/// If it's right anti join,
/// we should convert the probe to nullable if the build side is
nullable.
diff --git a/regression-test/data/query_p0/join/rqg/rqg12257/rqg12257.out
b/regression-test/data/query_p0/join/rqg/rqg12257/rqg12257.out
new file mode 100644
index 00000000000..e82718978b6
--- /dev/null
+++ b/regression-test/data/query_p0/join/rqg/rqg12257/rqg12257.out
@@ -0,0 +1,5 @@
+-- This file is automatically generated. You should know what you did if you
want to edit this
+-- !rqg12257 --
+
+-- !rqg12257_2 --
+
diff --git a/regression-test/suites/query_p0/join/rqg/rqg12257/rqg12257.groovy
b/regression-test/suites/query_p0/join/rqg/rqg12257/rqg12257.groovy
new file mode 100644
index 00000000000..c04a1f460d4
--- /dev/null
+++ b/regression-test/suites/query_p0/join/rqg/rqg12257/rqg12257.groovy
@@ -0,0 +1,341 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements. See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership. The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied. See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+suite("rqg12257") {
+ String db = context.config.getDbNameByFile(context.file)
+
+ multi_sql """
+ drop database if exists ${db};
+ create database ${db};
+ use ${db};
+
+create table table_200_undef_partitions2_keys3_properties4_distributed_by52 (
+col_int_undef_signed int null ,
+col_date_undef_signed date null ,
+col_int_undef_signed_not_null int not null ,
+col_date_undef_signed_not_null date not null ,
+col_varchar_5__undef_signed varchar(5) null ,
+col_varchar_5__undef_signed_not_null varchar(5) not null ,
+pk int
+) engine=olap
+DUPLICATE KEY(col_int_undef_signed, col_date_undef_signed)
+PARTITION BY RANGE(col_int_undef_signed) (
+ PARTITION p0 VALUES LESS THAN ('4'),
+ PARTITION p1 VALUES LESS THAN ('6'),
+ PARTITION p2 VALUES LESS THAN ('7'),
+ PARTITION p3 VALUES LESS THAN ('8'),
+ PARTITION p4 VALUES LESS THAN ('10'),
+ PARTITION p5 VALUES LESS THAN ('83647'),
+ PARTITION p100 VALUES LESS THAN ('2147483647')
+ )
+
+distributed by hash(pk) buckets 10
+properties("replication_num" = "1");
+insert into
table_200_undef_partitions2_keys3_properties4_distributed_by52(pk,col_int_undef_signed,col_int_undef_signed_not_null,col_date_undef_signed,col_date_undef_signed_not_null,col_varchar_5__undef_signed,col_varchar_5__undef_signed_not_null)
values
(0,26920,23303,'2023-12-12','2010-06-27','o','s'),(1,3,1,null,'2023-12-11','f','s'),(2,-27490,7,'2023-12-16','2023-12-13',null,'q'),(3,0,-3125347,'2023-12-18','2023-12-13','g','r'),(4,28062,2,'2023-12-11','2023-12-12','v','s'),(5,31608,3
[...]
+
+create table table_200_undef_partitions2_keys3_properties4_distributed_by5 (
+col_int_undef_signed int null ,
+col_int_undef_signed_not_null int not null ,
+col_date_undef_signed date null ,
+col_date_undef_signed_not_null date not null ,
+col_varchar_5__undef_signed varchar(5) null ,
+col_varchar_5__undef_signed_not_null varchar(5) not null ,
+pk int
+) engine=olap
+DUPLICATE KEY(col_int_undef_signed)
+PARTITION BY RANGE(col_int_undef_signed) (
+ PARTITION p0 VALUES LESS THAN ('4'),
+ PARTITION p1 VALUES LESS THAN ('6'),
+ PARTITION p2 VALUES LESS THAN ('7'),
+ PARTITION p3 VALUES LESS THAN ('8'),
+ PARTITION p4 VALUES LESS THAN ('10'),
+ PARTITION p5 VALUES LESS THAN ('83647'),
+ PARTITION p100 VALUES LESS THAN ('2147483647')
+ )
+
+distributed by hash(pk) buckets 10
+properties("replication_num" = "1");
+insert into
table_200_undef_partitions2_keys3_properties4_distributed_by5(pk,col_int_undef_signed,col_int_undef_signed_not_null,col_date_undef_signed,col_date_undef_signed_not_null,col_varchar_5__undef_signed,col_varchar_5__undef_signed_not_null)
+ values (0,2,2,null,'2023-12-14','c','y'),
+(1,9,1,'2015-06-20','2023-12-09','i','w'),
+(2,9,8,'2023-12-13','2023-12-12','p','p'),
+(3,null,1,'2023-12-18','2023-12-17','s','c'),
+(4,2,6,'2023-12-11','2023-12-13','f','a'),
+(5,1996613,-31050,'2023-12-09','2023-12-10',null,'j'),
+(6,3,0,'2023-12-15','2023-12-17','l','f'),
+(7,-24465,3,'2023-12-10','2023-12-09','a','n'),
+(8,6,5,'2023-12-18','2023-12-16',null,'e'),
+(9,5,1,'2023-12-12','2023-12-13','j','z'),
+(10,-8015300,4,'2023-12-13','2023-12-18','b','d'),
+(11,5,4,'2023-12-11','2023-12-13',null,'x'),
+(12,-14653,1,'2019-10-05','2005-09-05','s','m'),
+(13,7,0,'2023-12-12','2023-12-18','d','y'),
+(14,-262707,9,'2005-04-11','2023-12-15','o','s'),
+(15,5,7,'2023-12-16','2023-12-09',null,'n'),
+(16,4,1,'2023-12-10','2023-12-18',null,'a'),
+(17,6,0,null,'2004-09-23',null,'d'),
+(18,null,2,'2005-06-14','2023-12-17','p','s'),
+(19,6,5,'2023-12-11','2023-12-17','y','l'),
+(20,30613,7,null,'2023-12-13','h','r'),
+(21,0,2200815,'2023-12-17','2023-12-18',null,'h'),
+(22,9,0,'2023-12-13','2023-12-18','w','q'),
+(23,9,4,null,'2023-12-18',null,'i'),
+(24,-4939,8,'2023-12-10','2023-12-18','p','t'),
+(25,7,5,null,'2023-12-10','l','z'),
+(26,0,9,'2023-12-15','2023-12-17','a','v'),
+(27,9,-16167,'2023-12-17','2011-02-15','h','b'),
+(28,5,1,'2008-08-17','2023-12-10','k','t'),
+(29,null,8,'2023-12-10','2023-12-10','g','g'),
+(30,-5899,3,'2023-12-11','2000-07-21','z','x'),
+(31,3,6302479,'2023-12-17','2023-12-15','f','w'),
+(32,6,8,'2023-12-10','2023-12-14','e','j'),
+(33,-19533,1,'2023-12-16','2023-12-15','f','l'),
+(34,7,4,'2023-12-18','2023-12-10','w','k'),
+(35,1,1,'2023-12-09','2007-10-12','h','e'),
+(36,26116,4,'2023-12-14','2023-12-11','r','h'),
+(37,5,14276,null,'2023-12-16','k','g'),
+(38,1,4,'2023-12-11','2018-03-21','n','d'),
+(39,6,9,null,'2023-12-09','m','u'),
+(40,2,4,'2023-12-17','2023-12-15','o','h'),
+(41,2055246,6,'2023-12-17','2023-12-17','l','v'),
+(42,0,8,'2023-12-18','2006-12-06','o','y'),
+(43,2,-5875895,'2023-12-18','2005-02-05','s','p'),
+(44,1,9,'2023-12-11','2023-12-18',null,'u'),
+(45,2,-4172303,null,'2023-12-12','p','g'),
+(46,3,-1617,'2023-12-11','2023-12-12','c','e'),
+(47,7,-5472370,'2008-12-24','2001-04-26','b','m'),
+(48,-5129872,1,'2007-11-23','2023-12-14',null,'m'),
+(49,-14398,-7152997,'2023-12-18','2023-12-17','x','v'),
+(50,5,6,'2023-12-16','2023-12-18','r','j'),
+(51,5,-5229938,'2023-12-14','2023-12-14','l','p'),
+(52,2,0,'2023-12-15','2023-12-17','x','v'),
+(53,-5984631,5,'2023-12-11','2023-12-14',null,'d'),
+(54,4565561,5,'2023-12-11','2023-12-11','z','l'),
+(55,3,6,'2023-12-13','2023-12-18','j','w'),
+(56,6,-4748871,'2023-12-15','2023-12-14','s','y'),
+(57,9,8,'2023-12-14','2023-12-13','e','a'),
+(58,0,5,null,'2023-12-18','x','v'),
+(59,2,7,'2023-12-09','2023-12-09','o','p'),
+(60,null,-2628279,'2000-02-12','2023-12-18','j','y'),
+(61,1,6,'2023-12-13','2023-12-14','z','l'),
+(62,3,5,null,'2023-12-14','z','n'),
+(63,-18999,5021804,'2023-12-09','2004-02-18','h','z'),
+(64,8367273,-379,'2023-12-12','2023-12-10','o','w'),
+(65,6,-6344751,'2023-12-14','2023-12-18','e','d'),
+(66,6,-2551034,'2009-10-07','2023-12-17','x','y'),
+(67,8,9,'2023-12-12','2023-12-11','x','c'),
+(68,-329988,8,'2023-12-18','2023-12-15','e','l'),
+(69,-6403336,28987,'2023-12-14','2023-12-15','a','y'),
+(70,20727,-19935,null,'2023-12-16',null,'z'),
+(71,4,3,null,'2023-12-15','o','y'),
+(72,6,-20445,null,'2023-12-09','t','f'),
+(73,0,1,'2023-12-17','2023-12-18','k','v'),
+(74,-25018,-27762,'2003-02-14','2002-02-05','z','d'),
+(75,0,9,'2023-12-12','2018-05-17','y','n'),
+(76,5,1,'2023-12-17','2023-12-18','t','k'),
+(77,null,6,'2017-08-25','2023-12-09','s','m'),
+(78,7,7,'2023-12-11','2023-12-15','e','z'),
+(79,8,4067211,'2003-08-18','2023-12-15','q','e'),
+(80,-2782101,7,'2023-12-15','2023-12-09',null,'n'),
+(81,4,3,'2015-04-19','2023-12-10','l','s'),
+(82,null,22109,'2023-12-15','2023-12-16','w','c'),
+(83,9,1,'2023-12-14','2023-12-12','k','q'),
+(84,-9488,-4795,'2023-12-12','2023-12-18','y','y'),
+(85,1,-6072344,'2023-12-12','2023-12-13','m','a'),
+(86,1,2,null,'2023-12-11','v','d'),
+(87,null,1,'2023-12-11','2023-12-10',null,'d'),
+(88,7270119,5,'2023-12-17','2008-02-04','v','c'),
+(89,2,8,'2023-12-15','2023-12-10','g','l'),
+(90,-4711688,-4031594,'2023-12-09','2023-12-13','d','f'),
+(91,null,1395,'2023-12-10','2023-12-15','a','i'),
+(92,3,7,null,'2023-12-10','v','r'),
+(93,6,3,null,'2023-12-09','q','l'),
+(94,28468,5,'2023-12-09','2023-12-17','f','k'),
+(95,9,6,null,'2016-02-02',null,'m'),
+(96,-2329254,3,'2023-12-12','2023-12-18','k','n'),
+(97,null,-7409880,'2023-12-09','2023-12-15','h','j'),
+(98,3,6,'2002-01-11','2000-02-08','s','b'),
+(99,2,4,'2023-12-14','2000-09-17',null,'v'),
+(100,7,-1364635,'2023-12-17','2023-12-10','i','a'),
+(101,null,8,'2023-12-13','2023-12-13','y','u'),
+(102,5,9,'2023-12-13','2023-12-18','e','q'),
+(103,null,-702546,'2023-12-15','2012-06-12','t','z'),
+(104,23537,2,'2023-12-12','2023-12-17','h','p'),
+(105,null,8,'2023-12-12','2023-12-18',null,'y'),
+(106,6,1,null,'2017-05-19','c','z'),
+(107,4342993,5,'2023-12-12','2023-12-18','g','a'),
+(108,4,7,'2023-12-12','2023-12-14','m','p'),
+(109,6,8,'2023-12-18','2017-11-22','a','i'),
+(110,6,-5615791,'2015-11-02','2023-12-09','j','s'),
+(111,8,4,'2023-12-09','2023-12-16',null,'z'),
+(112,2,7691121,null,'2023-12-09','q','r'),
+(113,null,3,'2023-12-13','2023-12-12','u','x'),
+(114,1,4398947,'2023-12-09','2023-12-13',null,'u'),
+(115,null,7,'2023-12-11','2023-12-09','n','c'),
+(116,-16785,-1536603,'2023-12-10','2023-12-13','c','f'),
+(117,-30978,-1350,null,'2023-12-11','t','d'),
+(118,6,5973689,null,'2023-12-15',null,'u'),
+(119,7,3,'2023-12-15','2023-12-14','w','e'),
+(120,3,9,'2023-12-12','2023-12-15','a','k'),
+(121,null,6,'2017-08-06','2023-12-18','p','h'),
+(122,4,8,'2018-03-28','2023-12-16','x','b'),
+(123,7,20865,'2023-12-17','2023-12-10','g','x'),
+(124,3,5,'2023-12-18','2023-12-16','c','h'),
+(125,null,-7162178,'2005-04-21','2023-12-17','j','s'),
+(126,3,1,'2010-01-10','2019-06-28','a','i'),
+(127,8,7,'2023-12-17','2008-12-28','p','y'),
+(128,-8425,19060,'2005-03-13','2010-09-06','r','z'),
+(129,5,9,'2023-12-16','2001-04-21','i','d'),
+(130,7,0,'2023-12-11','2023-12-15','c','y'),
+(131,4,8,'2023-12-12','2017-08-14','m','u'),
+(132,-5332663,3,'2023-12-18','2023-12-16','v','k'),
+(133,-11973,-4263523,'2023-12-18','2023-12-18',null,'k'),
+(134,4,1,'2023-12-15','2023-12-13','e','j'),
+(135,6,2420,null,'2023-12-13','y','s'),
+(136,7768,7,null,'2023-12-13','y','r'),
+(137,-2223,7,'2007-04-28','2023-12-18',null,'d'),
+(138,4,2,'2023-12-14','2011-06-13','h','k'),
+(139,5379,2,'2023-12-18','2023-12-09','r','k'),
+(140,7971660,8,'2023-12-17','2018-06-28','u','b'),
+(141,3,5,'2023-12-17','2023-12-13','h','i'),
+(142,2330337,5,'2023-12-18','2000-08-28','o','a'),
+(143,6501282,6,'2023-12-10','2023-12-17','k','j'),
+(144,8,5,'2023-12-16','2023-12-09','l','m'),
+(145,2,8026441,'2023-12-10','2023-12-14','j','t'),
+(146,8,-7960122,'2023-12-09','2023-12-11','z','g'),
+(147,-23723,1,'2023-12-16','2023-12-15','l','x'),
+(148,9,7,'2023-12-13','2023-12-10',null,'w'),
+(149,7,-7300336,'2002-08-02','2002-08-27','u','p'),
+(150,null,1,null,'2023-12-10','s','t'),
+(151,null,7,'2023-12-18','2023-12-14','k','l'),
+(152,3,5,'2023-12-10','2006-03-01','d','f'),
+(153,6,2307292,'2023-12-15','2023-12-09','o','u'),
+(154,3757534,-6753340,'2023-12-13','2019-02-15','y','g'),
+(155,0,4943873,'2023-12-16','2023-12-13','k','i'),
+(156,3,2,'2023-12-13','2023-12-16','i','y'),
+(157,8,4,'2023-12-09','2023-12-10','a','y'),
+(158,1,9,'2023-12-12','2023-12-15','u','p'),
+(159,8,7840509,null,'2008-06-19','l','x'),
+(160,23010,5,'2017-12-20','2023-12-15','p','q'),
+(161,0,0,null,'2023-12-18','g','m'),
+(162,9,3705780,'2023-12-16','2023-12-12','o','a'),
+(163,null,-17022,'2023-12-13','2023-12-13','s','k'),
+(164,null,6,'2023-12-14','2023-12-13','s','e'),
+(165,null,8,'2023-12-15','2023-12-16','o','e'),
+(166,0,6,'2023-12-14','2023-12-16',null,'w'),
+(167,3297576,8,'2023-12-17','2023-12-14','a','z'),
+(168,9,0,'2023-12-18','2023-12-11','n','o'),
+(169,7,6,null,'2023-12-09','m','m'),
+(170,4,5592370,'2023-12-10','2023-12-15',null,'t'),
+(171,2656389,9,'2023-12-14','2023-12-12',null,'h'),
+(172,8,1,'2023-12-12','2002-06-27','z','q'),
+(173,8,3,'2023-12-15','2023-12-14','d','w'),
+(174,17473,4,'2004-11-26','2023-12-10','t','o'),
+(175,7,-17330,'2023-12-14','2023-12-14','d','i'),
+(176,2,-31652,null,'2023-12-09','n','e'),
+(177,9,0,'2023-12-09','2023-12-13','c','t'),
+(178,-7603492,4,'2023-12-09','2023-12-14','l','g'),
+(179,null,32549,null,'2023-12-12','p','m'),
+(180,0,-6415,'2023-12-11','2023-12-11','b','u'),
+(181,-26321,8,null,'2023-12-13','o','j'),
+(182,1,10798,'2023-12-16','2023-12-18','x','s'),
+(183,5,4,'2023-12-11','2023-12-16','d','c'),
+(184,2810913,9,'2023-12-14','2023-12-16','d','t'),
+(185,1707,7,null,'2023-12-14','m','i'),
+(186,null,4,null,'2023-12-17','s','q'),
+(187,6,3,'2023-12-15','2010-12-17','k','i'),
+(188,-12254,-12199,'2023-12-18','2023-12-11','q','f'),
+(189,3,6,'2023-12-12','2023-12-14',null,'y'),
+(190,-5041887,4,'2013-03-27','2023-12-14','w','w'),
+(191,5,1,null,'2023-12-10','f','o'),
+(192,0,8,'2023-12-10','2023-12-17','d','g'),
+(193,7,5,'2023-12-11','2023-12-18','z','v'),
+(194,9,5,null,'2023-12-18','l','k'),
+(195,2,7,null,'2023-12-11','m','i'),
+(196,null,5,'2023-12-09','2023-12-16','q','e'),
+(197,null,2,'2023-12-16','2023-12-16','h','u'),
+(198,-8622,1,'2023-12-10','2023-12-15','q','f'),
+(199,1,8,'2012-06-28','2023-12-10','e','y');
+
+create table table_20_undef_partitions2_keys3_properties4_distributed_by54 (
+col_date_undef_signed date null ,
+col_int_undef_signed int null ,
+col_int_undef_signed_not_null int not null ,
+col_date_undef_signed_not_null date not null ,
+col_varchar_5__undef_signed varchar(5) null ,
+col_varchar_5__undef_signed_not_null varchar(5) not null ,
+pk int
+) engine=olap
+DUPLICATE KEY(col_date_undef_signed)
+PARTITION BY RANGE(col_date_undef_signed) (
+ PARTITION p0 VALUES LESS THAN ('2023-12-11'),
+ PARTITION p1 VALUES LESS THAN ('2023-12-15'),
+ PARTITION p2 VALUES LESS THAN ('2023-12-16'),
+ PARTITION p3 VALUES LESS THAN ('2023-12-17'),
+ PARTITION p4 VALUES LESS THAN ('2024-01-18'),
+ PARTITION p5 VALUES LESS THAN ('2026-02-18'),
+ PARTITION p100 VALUES LESS THAN ('9999-12-31')
+ )
+
+distributed by hash(pk) buckets 10
+properties("replication_num" = "1");
+insert into
table_20_undef_partitions2_keys3_properties4_distributed_by54(pk,col_int_undef_signed,col_int_undef_signed_not_null,col_date_undef_signed,col_date_undef_signed_not_null,col_varchar_5__undef_signed,col_varchar_5__undef_signed_not_null)
values
(0,2611214,8,null,'2023-12-12','u','m'),(1,8,6,'2023-12-17','2004-05-24','o','s'),(2,null,4,'2023-12-09','2023-12-11','w','g'),(3,14231,1,'2023-12-18','2023-12-13',null,'q'),(4,3,9,'2023-12-13','2016-01-27','h','k'),(5,null,9,'2023-12-09'
[...]
+ """
+
+ Thread.sleep(70000) // wait for row count report of the tables just loaded
+ // sql """ ANALYZE TABLE
table_200_undef_partitions2_keys3_properties4_distributed_by52 WITH SYNC """
+ // sql """ ANALYZE TABLE
table_200_undef_partitions2_keys3_properties4_distributed_by5 WITH SYNC """
+ // sql """ ANALYZE TABLE
table_20_undef_partitions2_keys3_properties4_distributed_by54 WITH SYNC """
+
+ qt_rqg12257 """
+SELECT
+ 6 + (tbl_alias1.col_int_undef_signed_not_null) AS col_alias1,
+ (9) col_alias2,
+ SUM (
+ (
+ 1 + (
+ CASE
+ WHEN (
+ LENGTH (tbl_alias1.col_varchar_5__undef_signed) <=> (6
- (1))
+ ) THEN (3)
+ ELSE ((8))
+ END
+ )
+ )
+ ) col_alias3,
+ SUM (DISTINCT tbl_alias1.col_int_undef_signed) AS col_alias4
+FROM
+ table_200_undef_partitions2_keys3_properties4_distributed_by52 AS
tbl_alias1
+ LEFT JOIN table_200_undef_partitions2_keys3_properties4_distributed_by52
AS tbl_alias2 ON tbl_alias1.col_varchar_5__undef_signed_not_null >=
tbl_alias1.col_varchar_5__undef_signed
+ RIGHT JOIN table_200_undef_partitions2_keys3_properties4_distributed_by5
AS tbl_alias3 ON tbl_alias1.col_varchar_5__undef_signed >=
tbl_alias1.col_date_undef_signed_not_null FULL
+ JOIN table_20_undef_partitions2_keys3_properties4_distributed_by54 AS
tbl_alias4 ON tbl_alias1.col_date_undef_signed_not_null <=>
tbl_alias4.col_date_undef_signed_not_null
+WHERE
+ NOT (
+ tbl_alias3.col_varchar_5__undef_signed_not_null <
tbl_alias1.col_varchar_5__undef_signed_not_null
+ )
+GROUP BY
+ col_alias1,
+ col_alias2
+ORDER BY
+ col_alias1,
+ col_alias2,
+ col_alias3,
+ col_alias4 ASC
+LIMIT
+ 10 OFFSET 100;
+ """
+}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
