[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1480, in check
    tools.assert_count_equal(
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 1272, in assertCountEqual
    self.fail(msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 753, in fail
    raise self.failureException(msg)
AssertionError: Element counts were not equal:
First has 1, Second has 0:  '7\t10\t13'
First has 0, Second has 1:  "E: (1064, 'Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] ')" : sql result not match:
- [SQL]: select sum(c1),sum(c1+1),sum(c1+2) from t1;
- [exp]: ['7\t10\t13']
- [act]: ["E: (1064, 'Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] ')"]
---

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_rewrite_sum_by_associative_rule ?[0m
?[1;32m[case file]: sql/test_sum_rewrite/R/test_sum_rewrite ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_8e57b00f7ecf48cfb7185bb603081443;
[SQL]: USE test_db_8e57b00f7ecf48cfb7185bb603081443;
	 → case db: ['test_db_8e57b00f7ecf48cfb7185bb603081443']
	 → case resource: []
create table t0 (
    c0 int,
    c1 int not null
) duplicate key(c0) distributed by hash(c0) buckets 3 properties("replication_num" = "1");
create table t1 (
    c0 int,
    c1 int not null
) duplicate key(c0) distributed by hash(c0) buckets 3 properties("replication_num" = "1");
insert into t0 values (1,1),(2,2),(3,3);
insert into t1 values (1,1),(2,2),(NULL,4);
select sum(c0),sum(c0+1),sum(c0+2) from t1;
select c1, sum(c0),sum(c0+1),sum(c0+2) from t1 group by c1 order by c1;
select sum(c1),sum(c1+1),sum(c1+2) from t1;
?[1;32m******************** [FINISH] test_rewrite_sum_by_associative_rule ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1480, in check
    tools.assert_count_equal(
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 1272, in assertCountEqual
    self.fail(msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 753, in fail
    raise self.failureException(msg)
AssertionError: Element counts were not equal:
First has 1, Second has 0:  '426666'
First has 0, Second has 1:  "E: (1064, 'Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] ')" : sql result not match:
- [SQL]: select count(1) from t1 
where 
    concat(c_str_5_low_non_null1, '1') < 'zzzz'
    and c_str_3_low1 = 'a1';
- [exp]: ['426666']
- [act]: ["E: (1064, 'Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] ')"]
---

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_parse_and_rewrite_or_predicate ?[0m
?[1;32m[case file]: sql/test_scan/test_pushdown_or_predicate/R/test_parse_and_rewrite_or_predicate ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_531709875d754525b1ad9bf367976607;
[SQL]: USE test_db_531709875d754525b1ad9bf367976607;
	 → case db: ['test_db_531709875d754525b1ad9bf367976607']
	 → case resource: []
set scan_or_to_union_limit = 1;
set enable_profile = true;
set enable_async_profile=false;
CREATE TABLE __row_util_base (
  k1 bigint NULL
) ENGINE=OLAP
DUPLICATE KEY(`k1`)
DISTRIBUTED BY HASH(`k1`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
insert into __row_util_base select generate_series from TABLE(generate_series(0, 10000 - 1));
insert into __row_util_base select * from __row_util_base; -- 20000
insert into __row_util_base select * from __row_util_base; -- 40000
insert into __row_util_base select * from __row_util_base; -- 80000
insert into __row_util_base select * from __row_util_base; -- 160000
insert into __row_util_base select * from __row_util_base; -- 320000
insert into __row_util_base select * from __row_util_base; -- 640000
insert into __row_util_base select * from __row_util_base; -- 1280000

CREATE TABLE __row_util (
  idx bigint NULL
) ENGINE=OLAP
DUPLICATE KEY(`idx`)
DISTRIBUTED BY HASH(`idx`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
insert into __row_util select row_number() over() as idx from __row_util_base;
CREATE TABLE t1 (
  k1 bigint NULL,
  c_int_1_seq bigint NULL,
  c_int_2_seq bigint NULL,

  c_str_1_seq String NULL,
  c_str_2_seq String NULL,

  c_str_3_low1 String NULL,
  c_str_4_low2 String NULL,

  c_str_5_low_non_null1 String NOT NULL,
  c_str_6_low_non_null2 String NOT NULL,

  c_str_7_seq_non_null1 String NOT NULL,
  c_str_8_seq_non_null2 String NOT NULL,

  c_date_1_seq date NULL,
  c_date_2_seq date NULL,
  c_datetime_1_seq datetime NULL,
  c_datetime_2_seq datetime NULL
) ENGINE=OLAP
DUPLICATE KEY(`k1`)
DISTRIBUTED BY HASH(`k1`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
insert into t1
select 
    idx,
    idx + 1280000,
    idx + 1280000*2,

    concat('abc1-', idx),
    concat('abc2-', idx),
    case when idx % 3 = 0 then 'a1' when idx % 3 = 1 then 'b1' else 'c1' end,
    case when idx < 1280000/4 then 'a2' when idx < 1280000/4*2 then 'b2' when idx < 1280000/4*3 then 'c2' else 'd2' end,

    case when idx % 3 = 0 then 'a1' when idx % 3 = 1 then 'b1' else 'c1' end,
    case when idx < 1280000/4 then 'a2' when idx < 1280000/4*2 then 'b2' when idx < 1280000/4*3 then 'c2' else 'd2' end,
    concat('abc1-', idx),
    concat('abc2-', idx),

    cast(date_sub('2023-11-02', interval cast(idx % 100 as int) day) as date),
    cast(date_sub('2023-11-02', interval cast(idx % 1000 as int) day) as date),
    
    date_sub('2023-11-02', interval cast(idx % (100 * 3600 * 24) as int) second),
    date_sub('2023-11-02', interval cast(idx % (1000 * 3600 * 24) as int) second)
from __row_util ;
insert into t1 (k1, c_str_5_low_non_null1, c_str_6_low_non_null2, c_str_7_seq_non_null1, c_str_8_seq_non_null2) select null, '<null>', '<null>', '<null>', '<null>';
insert into t1 (k1, c_str_5_low_non_null1, c_str_6_low_non_null2, c_str_7_seq_non_null1, c_str_8_seq_non_null2) select null, '<null>', '<null>', '<null>', '<null>';
CREATE TABLE t2 (
  k1 bigint NULL,
  c_int_1_seq bigint SUM NULL,
  c_int_2_seq bigint SUM NULL,
  c_str_1_seq String MAX NULL,
  c_str_2_seq String MAX NULL,
  c_str_3_low1 String MAX NULL,
  c_str_4_low2 String MAX NULL,

  c_str_5_low_non_null1 String MAX NOT NULL,
  c_str_6_low_non_null2 String MAX NOT NULL,

  c_str_7_seq_non_null1 String MAX NOT NULL,
  c_str_8_seq_non_null2 String MAX NOT NULL,

  c_date_1_seq date MAX NULL,
  c_date_2_seq date MAX NULL,
  c_datetime_1_seq datetime MAX NULL,
  c_datetime_2_seq datetime MAX NULL
) ENGINE=OLAP
AGGREGATE KEY(`k1`)
DISTRIBUTED BY HASH(`k1`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
insert into t2 select * from t1;
insert into t2 select * from t1;
create view __pred_profile(idx, k, v) as 
select 1, 2, 3;
select *
from t1
where 
  k1 = 1 or c_int_1_seq = 1280000+2 
order by k1;
select * from __pred_profile order by idx, k, v;
select *
from t1
where 
  k1 = 1 or c_int_1_seq = 1280000+2 or k1 + c_int_1_seq = 1280000+3+3;
select * from __pred_profile order by idx, k, v;
select *
from t1
where 
  (k1 = 1 or c_int_1_seq = 1280000+2 or k1 + c_int_1_seq = 1280000+3+3) and (k1 < 3);
select * from __pred_profile order by idx, k, v;
select *
from t1
where 
  c_int_1_seq = 1280000+2 and (k1 = 1 or (k1 < 3 and k1 + c_int_1_seq = 1280000+3+3));
select * from __pred_profile order by idx, k, v;
select *
from t2
where 
  (k1 = 1 or c_int_1_seq = 1280000+2) and (k1 < 3)
order by k1;
select * from __pred_profile order by k, v;
select *
from t2
where 
  ((k1 = 1 or k1=2 ) and k1 < 3) or (k1 = 4)
order by k1;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000);
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000, null);
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_int_1_seq = 1280000+10;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where 1280000+10 = c_int_1_seq;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'abc1-128';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_3_low1 = 'a1';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq in ('2023-11-01','2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq = '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq = '2023-11-01 01:00:00';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_datetime_2_seq in ('2023-11-01', '2023-11-01 01:00:00', '2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_datetime_2_seq = '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000);
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000, null);
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq = 1280000+10;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or 1280000+10 = c_int_1_seq;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_str_1_seq = 'abc1-128';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_str_3_low1 = 'a1';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq in ('2023-11-01','2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq = '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq = '2023-11-01 01:00:00';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq in ('2023-11-01', '2023-11-01 01:00:00', '2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq = '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_int_1_seq < 1280000+20;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_int_1_seq <= 1280000+20;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where 1280000+20 > c_int_1_seq;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where 1280000+20 >= c_int_1_seq;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_int_1_seq != 1280000+20;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where 1280000+20 != c_int_1_seq;
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq > '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq > '2023.11.01 01:00:00';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq >= '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq >= '2023.11.01 01:00:00';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq < '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq < '2023.11.01 01:00:00';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq <= '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_date_1_seq <= '2023.11.01 01:00:00';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_datetime_2_seq > '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_datetime_2_seq >= '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_datetime_2_seq < '2023-11-01';
select * from __pred_profile order by idx, k, v;
select count(1) from t1 where c_datetime_2_seq <= '2023-11-01';
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq < 1280000+20;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq <= 1280000+20;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or 1280000+20 > c_int_1_seq;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or 1280000+20 >= c_int_1_seq;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq != 1280000+20;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or 1280000+20 != c_int_1_seq;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq > '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq > '2023.11.01 01:00:00';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq >= '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq >= '2023.11.01 01:00:00';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq < '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq < '2023.11.01 01:00:00';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq <= '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq <= '2023.11.01 01:00:00';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq > '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq >= '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq < '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq <= '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000);
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000, null);
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq != 1280000+10;
select * from __pred_profile order by k, v;
select count(1) from t1 where 1280000+10 != c_int_1_seq;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq != 'abc1-128';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_date_1_seq not in ('2023-11-01','2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_date_1_seq != '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_date_1_seq != '2023-11-01 01:00:00';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_datetime_2_seq not in ('2023-11-01', '2023-11-01 01:00:00', '2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_datetime_2_seq != '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000);
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000, null);
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq != 1280000+10;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or 1280000+10 != c_int_1_seq;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_str_1_seq != 'abc1-128';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq not in ('2023-11-01','2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq != '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_date_1_seq != '2023-11-01 01:00:00';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq not in ('2023-11-01', '2023-11-01 01:00:00', '2023-10-10', '2023-09-10', '2023-10-09 01:00:00', '2023-10-10 01:00:00');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_datetime_2_seq != '2023-11-01';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq is null;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq is not null;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq is not null and c_int_1_seq is null;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq is null;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'not-found' or c_int_1_seq is not null;
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq is not null or c_int_1_seq is null;  
  select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq in (1280000+10, 1280000+100);
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq not in (1280000+10, 1280000+100, 1280000+300);
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq < 1280000+1000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq <= 1280000+1000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq > 1280000+100;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq > 1280000+100;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq > 1280000+1000
  and c_int_1_seq < 1280000+10000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq >= 1280000+10000
  and c_int_1_seq <= 1280000+10000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq < 1280000+1000
  and c_int_1_seq > 1280000+10000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  and c_int_1_seq < 1280000+1000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq not in (1280000+10, 1280000+100);
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq in (1280000+10, 1280000+100, 1280000+300);
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq >= 1280000+1000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq > 1280000+500;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq <= 1280000+100;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq not in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq < 1280000+100;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq <= 1280000+1000
  or c_int_1_seq >= 1280000+10000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq < 1280000+10000
  or c_int_1_seq > 1280000+10000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq >= 1280000+1000
  or c_int_1_seq <= 1280000+10000;
select * from __pred_profile order by k, v;
select count(1) from t1 where 
  c_int_1_seq in (1280000+10, 1280000+100, 1280000+1000, 180000+10000)
  or c_int_1_seq >= 1280000+1000;
select * from __pred_profile order by k, v;
select *
from t1
where 
  (k1 in (123, 456) or c_int_1_seq = 1280000+2 or k1 in (1, 2)) and (c_str_3_low1 = 'a1' or c_str_4_low2 = 'a2');
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (k1 > 100 or k1 < 1000) or c_int_1_seq = 1280000+2;
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (k1 < 100 or k1 > 1000 or c_int_1_seq = 1280000+2) and (c_str_3_low1 = 'a1' or c_str_4_low2 = 'a2');
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (k1 > 1000 or k1 = 10000 or k1 < 100) or c_int_1_seq = 1280000+2 ;
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  ((k1 > 1000 or k1 not in (999)) or (k1 < 100 or k1 not in (1))) or c_int_1_seq = 1280000+2 ;
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  ((k1 > 1000 or k1 not in (999)) or (k1 < 100 or k1 not in (1)) or k1 is null) or c_int_1_seq = 1280000+2 or (c_int_2_seq is null or c_int_2_seq is not null);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  ((k1 > 1000 or k1 not in (999)) or (k1 < 100 or k1 not in (1)) or k1 is null);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  c_int_1_seq = 1280000+2 or (c_int_2_seq is null or c_int_2_seq is not null);
select * from __pred_profile order by k, v;
with 
  w1 as (select * from t1 where k1 < 1280000 / 4),
  w2 as (select * from t1 where k1 < 10),
  w3 as (select * from t1 where c_int_1_seq = 1280000+2 or (c_int_2_seq is null or c_int_2_seq is not null))
select count(1) 
from 
  w3
    join [colocate] w1 on w3.k1 = w1.k1
    join [colocate] w2 on w3.k1 = w2.k1;
select * from __pred_profile order by k, v;
with 
  w1 as (select * from t1 where k1 < 1280000 / 4),
  w2 as (select * from t1 where k1 < 10),
  w3 as (select * from t1 where c_int_1_seq = 1280000+2 or (c_int_2_seq is null or c_int_2_seq is not null))
select count(1) 
from 
  w3
    join [broadcast] w1 on w3.k1 = w1.k1
    join [broadcast] w2 on w3.k1 = w2.k1;
select * from __pred_profile order by k, v;
with 
  w1 as (select * from t1 where k1 < 1280000 / 4),
  w2 as (select * from t1 where k1 < 10),
  w3 as (select * from t1 where c_int_1_seq = 1280000+2 or (c_int_2_seq is null or c_int_2_seq is not null))
select /*+SET_VAR(runtime_filter_scan_wait_time=20000)*/ count(1) 
from 
  w3
    join [shuffle] w1 on w3.k1 = w1.k1
    join [shuffle] w2 on w3.k1 = w2.k1;
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (c_int_1_seq * 2 < 1280000 * 2 * 11 / 10);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (c_int_1_seq * 2 = 1280000 * 2 * 11 / 10);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (c_int_1_seq * 2 = 1280000 * 2 * 11 / 10) or (c_int_1_seq * 2 < 1280000 * 2 * 11 / 10);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (c_int_1_seq * 2 = 1280000 * 2 * 11 / 10) and (c_int_1_seq * 2 < 1280000 * 2 * 12 / 10);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  ((c_int_1_seq * 2 = 1280000 * 2 * 11 / 10) and (c_int_1_seq * 2 < 1280000 * 2 * 12 / 10)) or
   (c_int_1_seq * 2 = 1280000 * 2 * 11 / 10) or (c_int_1_seq * 2 < 1280000 * 2 * 11 / 10);
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (c_int_1_seq < 1) or year(c_date_2_seq) = 2022;
select * from __pred_profile order by k, v;
select count(1)
from t1
where 
  (c_int_1_seq < 1) or year(c_date_2_seq) = 1998;
select * from __pred_profile order by k, v;
CREATE TABLE t1_copy (
  k1 bigint NULL,
  c_int_1_seq bigint NULL,
  c_int_2_seq bigint NULL,
  c_str_1_seq String NULL,
  c_str_2_seq String NULL,
  c_str_3_low1 String NULL,
  c_str_4_low2 String NULL,
  c_date_1_seq date NULL,
  c_date_2_seq date NULL,
  c_datetime_1_seq datetime NULL,
  c_datetime_2_seq datetime NULL
) ENGINE=OLAP
DUPLICATE KEY(`k1`)
DISTRIBUTED BY HASH(`k1`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
insert into t1_copy select * from t1;
analyze table t1_copy;
select count(1) from t1_copy;
select count(1) from t1_copy where c_str_3_low1 = 'a1';
select count(1) from t1_copy where c_str_3_low1 = 'b1';
delete from t1_copy where c_str_3_low1 = 'a1';
select count(1) from t1_copy;
select count(1) from t1_copy where c_str_3_low1 = 'a1';
select count(1) from t1_copy where c_str_3_low1 = 'b1';
delete from t1_copy where c_str_3_low1 = 'b1';
select count(1) from t1_copy;
select count(1) from t1_copy where c_str_3_low1 = 'a1';
select count(1) from t1_copy where c_str_3_low1 = 'b1';
truncate table t1_copy;
insert into t1_copy select * from t1;
select count(1) from t1_copy;
select count(1) from t1_copy where c_str_3_low1 = 'a1';
select count(1) from t1_copy where c_str_3_low1 = 'b1';
select count(1) from t1 where c_str_3_low1 = 'not-found';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq = 'abc1-69';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_5_low_non_null1 != 'not-found';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 != 'not-found';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq != 'abc1-69';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 in ('not-found1', 'not-found2');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 in ('not-found1', 'not-found2', 'a1');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq in ('not-found1', 'not-found2', 'abc1-69');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_5_low_non_null1 not in ('not-found1', 'not-found2');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 not in ('not-found1', 'not-found2');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 not in ('not-found1', 'not-found2', 'a1');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq not in ('not-found1', 'not-found2', 'abc1-69', 'abc1-89');
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 > 'zzzz';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 > 'a1';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 > 'a0';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 >= 'zzzz';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 >= 'a1';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 >= 'a2';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 >= 'a0';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 < 'a0';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_5_low_non_null1 < ';';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 < 'a2';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq < 'abc1-69';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 <= ';';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_5_low_non_null1 <= ';';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_3_low1 <= 'b2';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_str_1_seq <= 'abc1-69';
select * from __pred_profile order by k, v;
select count(1) from t1 where concat(c_str_3_low1, '1') < 'a0';
select * from __pred_profile order by k, v;
select count(1) from t1 where concat(c_str_5_low_non_null1, '1') < ';';
select * from __pred_profile order by k, v;
select count(1) from t1 where concat(c_str_5_low_non_null1, '1') < 'zzzz';
select * from __pred_profile order by k, v;
select count(1) from t1 where concat(c_str_3_low1, '1') < 'b1';
select * from __pred_profile order by k, v;
select count(1) from t1 where concat(c_str_5_low_non_null1, '1') < 'b1';
select * from __pred_profile order by k, v;
select count(1) from t1 where c_int_1_seq < 'a0';
select * from __pred_profile order by k, v;
select count(1) from t1 
where 
    concat(c_str_5_low_non_null1, '1') < 'zzzz'
    and c_str_3_low1 = 'a1';
?[1;32m******************** [FINISH] test_parse_and_rewrite_or_predicate ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (5025, '[E111]Fail to connect Socket{id=919 addr=172.21.251.135:8060} (0x0x7f6a2b40b180): Connection refused [R1][E112]Not connected to 172.21.251.135:8060 yet, server_id=919 [R2][E112]Not connected to 172.21.251.135:8060 yet, server_id=919 [R3][E112]Not connected to 172.21.251.135:8060 yet, server_id=919:  be:172.21.251.135: BE:10004'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf ?[0m
?[1;32m[case file]: sql/test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf/R/test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_525326bc617a4314a01bf0a113fb819a;
[SQL]: USE test_db_525326bc617a4314a01bf0a113fb819a;
	 → case db: ['test_db_525326bc617a4314a01bf0a113fb819a']
	 → case resource: []
DROP TABLE if exists t0;
CREATE TABLE if not exists t0
(
    c0 INT NOT NULL,
    c1 VARCHAR(32) NOT NULL,
    c2 VARCHAR(32) NOT NULL
    
) ENGINE=OLAP
DUPLICATE KEY(`c0`
)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c0`, `c1`
) BUCKETS 64
PROPERTIES(
    "replication_num" = "1",
    "in_memory" = "false",
    "storage_format" = "default"
    
);
DROP TABLE if exists t1;
CREATE TABLE if not exists t1
(
    c0 INT NOT NULL,
    c1 VARCHAR(32) NOT NULL,
    c2 VARCHAR(32) NOT NULL
    
) ENGINE=OLAP
DUPLICATE KEY(`c0`
)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c0`, `c1`
) BUCKETS 64
PROPERTIES(
    "replication_num" = "1",
    "in_memory" = "false",
    "storage_format" = "default"
    
);
DROP TABLE if exists t2;
CREATE TABLE if not exists t2
(
    c0 INT NOT NULL,
    c1 VARCHAR(32) NOT NULL,
    c2 VARCHAR(32) NOT NULL
    
) ENGINE=OLAP
DUPLICATE KEY(`c0`
)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c0`, `c1`
) BUCKETS 64
PROPERTIES(
    "replication_num" = "1",
    "in_memory" = "false",
    "storage_format" = "default"
    
);
INSERT INTO t0
(c0, c1, c2
)
VALUES
    ('4', 'DvvRNNLAAKj5mc3e', 'oHHGEp'
        ),
    ('8', 'YMV5W6K3Jcv5kp', 'dm9h5J8cHtX6GfDZ8J7odAIJxyZdJSa'
        ),
    ('4', 'nqrRk', 'D1ephlGonrHHWnY4ThjhO11'
        ),
    ('6', 'A9fWZWnk1WWTJ37', 'V'
        ),
    ('9', 'A6f2iV', 'kd2S'
        ),
    ('2', 'KxNCswN6q1xZgBmvGxjr24Y', '6SqBgNekQtxOWiZXBrZuaAI1r'
        ),
    ('2', 'Sl4ZtHpUMR6JKt0uYkcHvjsNs', 'TmysYNLEyxNGnkgk4NlbSAkS'
        ),
    ('8', '985m0SmtQLKH4zZHS', '9BRWRd8pAbBjtqFYfdaeu'
        ),
    ('7', 'TRXAIbYTmrTPV1F0', 'KJHp'
        ),
    ('3', 'GLRmc1tmqiHpyi4dMaAb0F', 'Q3OkhuxxGMDwTfo273'
        );
INSERT INTO t1
(c0, c1, c2
)
VALUES
    ('7', '5WUQFPf', '9GszO3v'
        ),
    ('4', 'uGywLy7', 'XdPwCy8Kb9wgLzco'
        ),
    ('6', '', 'QiWAR1yoW2TsD4hrC16saOw'
        ),
    ('8', 'a1HBEfnDhbed4gLtlq', '7QgGrBQDn14bTfdOLSKF'
        ),
    ('4', 'r2Igrl0jHPT', 'BPhnKYMqDSTQtXKUEKpjyKodTeLFI9'
        ),
    ('4', 'SAztGc55aDcK9jeAnq57eMsXEfYdHA', 'NEfQ'
        ),
    ('11', 'mtXUECE2TG23OLToBhvxpPaO', 'zxX'
        ),
    ('6', '', 'tji7m72J'
        ),
    ('6', '00RSjBQ71AuYlAZg', 'yGGjrU3Y'
        ),
    ('9', 'w', 'f9VzBNpbKLt5'
        );
?[1;32m******************** [FINISH] test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (5025, '[E111]Fail to connect Socket{id=8589934796 addr=172.21.251.135:8060:46958} (0x0x7fb50d985680): Connection refused [R1][E112]Not connected to 172.21.251.135:8060 yet, server_id=8589934796 [R2][E112]Not connected to 172.21.251.135:8060 yet, server_id=8589934796 [R3][E112]Not connected to 172.21.251.135:8060 yet, server_id=8589934796:  be:172.21.251.135'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_runtime_filter_push_down_on_left_join ?[0m
?[1;32m[case file]: sql/test_runtime_filter_push_down_on_left_join/R/test_runtime_filter_push_down_on_left_join ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_a87a51698d4346608577ad05c523e203;
[SQL]: USE test_db_a87a51698d4346608577ad05c523e203;
	 → case db: ['test_db_a87a51698d4346608577ad05c523e203']
	 → case resource: []
CREATE TABLE `t1` (
  c1 string,
  c2 string,
  c3 string
) ENGINE=OLAP
DUPLICATE KEY(`c1`)
DISTRIBUTED BY HASH(`c1`) BUCKETS 48
PROPERTIES (
  "replication_num" = "1"
);
CREATE TABLE `t2` (
  c1 string,
  c2 string,
  c3 string
) ENGINE=OLAP
DUPLICATE KEY(`c1`)
DISTRIBUTED BY HASH(`c1`) BUCKETS 48
PROPERTIES (
  "replication_num" = "1"
);
CREATE TABLE `t3` (
  c1 string,
  c2 string,
  c3 string
) ENGINE=OLAP
DUPLICATE KEY(`c1`)
DISTRIBUTED BY HASH(`c1`) BUCKETS 48
PROPERTIES (
  "replication_num" = "1"
);
insert into t3 select 'c1-1', 'unknown', 'c3';
insert into t2 select 'c1-1', 'c2-1', 'c3';
?[1;32m******************** [FINISH] test_runtime_filter_push_down_on_left_join ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 461, in test_sql_basic
    tools.ok_(False, err_msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/tools/trivial.py", line 16, in ok_
    raise AssertionError(msg)
AssertionError: [CONCURRENCY] FAIL:
	- Thread-thread name 2-1-0
	- Thread-thread name 1-0-0
	- Thread-thread name 5-4-0
	- Thread-thread name 4-3-0
	- Thread-thread name 3-2-0

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_resource_group_exclusive_cpu_cores_borrowing_cpu ?[0m
?[1;32m[case file]: sql/test_resource_group/R/test_resource_group_dedicated_cpu_cores_borrowing_cpu ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_49253aa663044f13ae13b51d8ca25e2b;
[SQL]: USE test_db_49253aa663044f13ae13b51d8ca25e2b;
	 → case db: ['test_db_49253aa663044f13ae13b51d8ca25e2b']
	 → case resource: []
CREATE TABLE __row_util_base (
  k1 bigint NULL
) ENGINE=OLAP
DUPLICATE KEY(`k1`)
DISTRIBUTED BY HASH(`k1`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
insert into __row_util_base select generate_series from TABLE(generate_series(0, 10000 - 1));
insert into __row_util_base select * from __row_util_base; -- 20000
insert into __row_util_base select * from __row_util_base; -- 40000
insert into __row_util_base select * from __row_util_base; -- 80000
insert into __row_util_base select * from __row_util_base; -- 160000
insert into __row_util_base select * from __row_util_base; -- 320000
insert into __row_util_base select * from __row_util_base; -- 640000
insert into __row_util_base select * from __row_util_base; -- 1280000

create table t1 (
    k1 int
)
duplicate key(k1)
distributed by hash(k1) buckets 32
properties("replication_num" = "1");
insert into t1 select row_number() over() as idx from __row_util_base;
CREATE RESOURCE GROUP rgd1_608f903e5e3044fe85fe4457f083c23a 
    TO ( user='user_608f903e5e3044fe85fe4457f083c23a' ) 
    WITH ( 'exclusive_cpu_cores' = '2', 'mem_limit' = '0.99' );
CREATE RESOURCE GROUP rgd2_608f903e5e3044fe85fe4457f083c23a 
    TO ( user='user_608f903e5e3044fe85fe4457f083c23a' ) 
    WITH ( 'exclusive_cpu_cores' = '2', 'mem_limit' = '0.99' );
CREATE RESOURCE GROUP rgn1_608f903e5e3044fe85fe4457f083c23a 
    TO ( user='user_608f903e5e3044fe85fe4457f083c23a' ) 
    WITH ( 'cpu_weight' = '3', 'mem_limit' = '0.99' );
CREATE RESOURCE GROUP rgn2_608f903e5e3044fe85fe4457f083c23a 
    TO ( user='user_608f903e5e3044fe85fe4457f083c23a' ) 
    WITH ( 'cpu_weight' = '3', 'mem_limit' = '0.99' );
SELECT count(1)
FROM 
    t1 
    join [broadcast] t1 t2 on t1.k1 = t2.k1
    join [bucket] t1 t3 on t1.k1 = t3.k1
    join [colocate] t1 t4 on t1.k1 = t4.k1
    join [shuffle] t1 t5 on t1.k1 = t5.k1;
?[36m[CONCURRENCY] Start... ?[0m
?[36mInit conn's db: test_db_49253aa663044f13ae13b51d8ca25e2b ?[0m
?[36mInit conn's db: test_db_49253aa663044f13ae13b51d8ca25e2b ?[0m
?[36mInit conn's db: test_db_49253aa663044f13ae13b51d8ca25e2b ?[0m
?[36mInit conn's db: test_db_49253aa663044f13ae13b51d8ca25e2b ?[0m
?[36mInit conn's db: test_db_49253aa663044f13ae13b51d8ca25e2b ?[0m
[SHELL]: mysql -h172.21.251.134 -P9032 -uroot --password=''  --comments -e "use test_db_49253aa663044f13ae13b51d8ca25e2b;SELECT /*+SET_VAR(resource_group='rgd1_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
[SHELL]: mysql -h172.21.251.134 -P9032 -uroot --password=''  --comments -e "use test_db_49253aa663044f13ae13b51d8ca25e2b;SELECT /*+SET_VAR(resource_group='rgd2_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
[SHELL]: mysql -h172.21.251.134 -P9032 -uroot --password=''  --comments -e "use test_db_49253aa663044f13ae13b51d8ca25e2b;SELECT /*+SET_VAR(resource_group='rgn1_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
[SHELL]: mysql -h172.21.251.134 -P9032 -uroot --password=''  --comments -e "use test_db_49253aa663044f13ae13b51d8ca25e2b;SELECT /*+SET_VAR(resource_group='rgn2_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
[SHELL]: mysql -h172.21.251.134 -P9032 -uroot --password=''  --comments -e "use test_db_49253aa663044f13ae13b51d8ca25e2b;SELECT count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
?[36m[thread name 1-0-0] Close connection... ?[0m
?[36m[thread name 2-1-0] Close connection... ?[0m
?[36m[thread name 3-2-0] Close connection... ?[0m
?[36m[thread name 4-3-0] Close connection... ?[0m
?[36m[thread name 5-4-0] Close connection... ?[0m
?[1;31m[CONCURRENCY] FAIL:
	- Thread-thread name 2-1-0
	- Thread-thread name 1-0-0
	- Thread-thread name 5-4-0
	- Thread-thread name 4-3-0
	- Thread-thread name 3-2-0 ?[0m
************************************************** Thread-thread name 2-1-0 **************************************************
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1129, in execute_thread
    self.check(_cmd_id_str, _each_cmd, expect_res, actual_res, order, ori_sql=cmd_list[_cmd_id].lstrip())
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1350, in check
    tools.assert_equal(int(exp.split("\n")[0]), act[0],
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 912, in assertEqual
    assertion_func(first, second, msg=msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 905, in _baseAssertEqual
    raise self.failureException(msg)
type: 0 != 1 : [SHELL ERROR]
	- cmd : shell: mysql -h${mysql_host} -P${mysql_port} -u${mysql_user} --password='${mysql_password}'  --comments -e "use ${db[0]};SELECT /*+SET_VAR(resource_group='rgd2_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
	- code: 1
	- msg : ERROR 1064 (HY000) at line 1: Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] 

************************************************** Thread-thread name 1-0-0 **************************************************
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1129, in execute_thread
    self.check(_cmd_id_str, _each_cmd, expect_res, actual_res, order, ori_sql=cmd_list[_cmd_id].lstrip())
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1350, in check
    tools.assert_equal(int(exp.split("\n")[0]), act[0],
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 912, in assertEqual
    assertion_func(first, second, msg=msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 905, in _baseAssertEqual
    raise self.failureException(msg)
type: 0 != 1 : [SHELL ERROR]
	- cmd : shell: mysql -h${mysql_host} -P${mysql_port} -u${mysql_user} --password='${mysql_password}'  --comments -e "use ${db[0]};SELECT /*+SET_VAR(resource_group='rgd1_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
	- code: 1
	- msg : ERROR 1064 (HY000) at line 1: Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] 

************************************************** Thread-thread name 5-4-0 **************************************************
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1129, in execute_thread
    self.check(_cmd_id_str, _each_cmd, expect_res, actual_res, order, ori_sql=cmd_list[_cmd_id].lstrip())
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1350, in check
    tools.assert_equal(int(exp.split("\n")[0]), act[0],
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 912, in assertEqual
    assertion_func(first, second, msg=msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 905, in _baseAssertEqual
    raise self.failureException(msg)
type: 0 != 1 : [SHELL ERROR]
	- cmd : shell: mysql -h${mysql_host} -P${mysql_port} -u${mysql_user} --password='${mysql_password}'  --comments -e "use ${db[0]};SELECT count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
	- code: 1
	- msg : ERROR 1064 (HY000) at line 1: Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] 

************************************************** Thread-thread name 4-3-0 **************************************************
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1129, in execute_thread
    self.check(_cmd_id_str, _each_cmd, expect_res, actual_res, order, ori_sql=cmd_list[_cmd_id].lstrip())
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1350, in check
    tools.assert_equal(int(exp.split("\n")[0]), act[0],
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 912, in assertEqual
    assertion_func(first, second, msg=msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 905, in _baseAssertEqual
    raise self.failureException(msg)
type: 0 != 1 : [SHELL ERROR]
	- cmd : shell: mysql -h${mysql_host} -P${mysql_port} -u${mysql_user} --password='${mysql_password}'  --comments -e "use ${db[0]};SELECT /*+SET_VAR(resource_group='rgn2_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
	- code: 1
	- msg : ERROR 1064 (HY000) at line 1: Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] 

************************************************** Thread-thread name 3-2-0 **************************************************
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 932, in _bootstrap_inner
    self.run()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1129, in execute_thread
    self.check(_cmd_id_str, _each_cmd, expect_res, actual_res, order, ori_sql=cmd_list[_cmd_id].lstrip())
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1350, in check
    tools.assert_equal(int(exp.split("\n")[0]), act[0],
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 912, in assertEqual
    assertion_func(first, second, msg=msg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 905, in _baseAssertEqual
    raise self.failureException(msg)
type: 0 != 1 : [SHELL ERROR]
	- cmd : shell: mysql -h${mysql_host} -P${mysql_port} -u${mysql_user} --password='${mysql_password}'  --comments -e "use ${db[0]};SELECT /*+SET_VAR(resource_group='rgn1_608f903e5e3044fe85fe4457f083c23a')*/ count(1) FROM t1 join [broadcast] t1 t2 on t1.k1 = t2.k1 join [bucket] t1 t3 on t1.k1 = t3.k1 join [colocate] t1 t4 on t1.k1 = t4.k1 join [shuffle] t1 t5 on t1.k1 = t5.k1;"
	- code: 1
	- msg : ERROR 1064 (HY000) at line 1: Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] 

?[1;32m******************** [FINISH] test_resource_group_exclusive_cpu_cores_borrowing_cpu ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (5025, '[E104]Fail to read from Socket{id=204 fd=207 addr=172.21.251.135:8060:59608} (0x0x7f69bd29b7c0): Connection reset by peer [R1][E112]Not connected to 172.21.251.135:8060 yet, server_id=204 [R2][E112]Not connected to 172.21.251.135:8060 yet, server_id=204 [R3][E112]Not connected to 172.21.251.135:8060 yet, server_id=204: BE:10004'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_pipeline_level_runtime_filter ?[0m
?[1;32m[case file]: sql/test_pipeline_level_runtime_filter/R/test_pipeline_level_runtime_filter ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_0d64afcbb6054a3791e30fbae9aabee1;
[SQL]: USE test_db_0d64afcbb6054a3791e30fbae9aabee1;
	 → case db: ['test_db_0d64afcbb6054a3791e30fbae9aabee1']
	 → case resource: []
DROP TABLE if exists t0;
CREATE TABLE if not exists t0
(
dt DATE NOT NULL,
c0 INT NOT NULL,
c1 INT NOT NULL
) ENGINE=OLAP
DUPLICATE KEY(`dt`, `c0`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c0`) BUCKETS 24
PROPERTIES(
"replication_num" = "1",
"storage_format" = "default",
"colocate_with" = "cgroup0"
);
DROP TABLE if exists t1;
CREATE TABLE if not exists t1
(
dt DATE NOT NULL,
c0 INT NOT NULL,
c1 INT NOT NULL
) ENGINE=OLAP
DUPLICATE KEY(`dt`, `c0`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c0`) BUCKETS 24
PROPERTIES(
"replication_num" = "1",
"storage_format" = "default",
"colocate_with" = "cgroup0"
);
DROP TABLE if exists seed0;
CREATE TABLE if not exists seed0
(
c INT NOT NULL
) ENGINE=OLAP
DUPLICATE KEY(`c`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c`) BUCKETS 32
PROPERTIES(
"replication_num" = "1",
"storage_format" = "default"
);
INSERT INTO seed0
  (c)
  select row_number() over() as r from (SELECT __tbl_7.__col_4 AS __col_8, __tbl_7.__col_5 AS __col_9, __tbl_7.__col_6 AS __col_10, __tbl_8.__col_7 AS __col_11 from (SELECT __tbl_4.__col_1 AS __col_4, __tbl_4.__col_2 AS __col_5, __tbl_5.__col_3 AS __col_6 from (SELECT __tbl_1.v AS __col_1, __tbl_2.__col_0 AS __col_2 from (select v from (values(0)) t(v)) AS __tbl_1, (SELECT __tbl_0.column_0 AS __col_0 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9),(10),(11),(12),(13),(14),(15),(16),(17),(18),(19),(20),(21),(22),(23),(24),(25),(26),(27),(28),(29),(30),(31),(32),(33),(34),(35),(36),(37),(38),(39),(40),(41),(42),(43),(44),(45),(46),(47),(48),(49),(50),(51),(52),(53),(54),(55),(56),(57),(58),(59),(60),(61),(62),(63),(64),(65),(66),(67),(68),(69),(70),(71),(72),(73),(74),(75),(76),(77),(78),(79),(80),(81),(82),(83),(84),(85),(86),(87),(88),(89),(90),(91),(92),(93),(94),(95),(96),(97),(98),(99),(100),(101)) __tbl_0) AS __tbl_2) AS __tbl_4, (SELECT __tbl_3.column_0 AS __col_3 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9),(10),(11),(12),(13),(14),(15),(16),(17),(18),(19),(20),(21),(22),(23),(24),(25),(26),(27),(28),(29),(30),(31),(32),(33),(34),(35),(36),(37),(38),(39),(40),(41),(42),(43),(44),(45),(46),(47),(48),(49),(50),(51),(52),(53),(54),(55),(56),(57),(58),(59),(60),(61),(62),(63),(64),(65),(66),(67),(68),(69),(70),(71),(72),(73),(74),(75),(76),(77),(78),(79),(80),(81),(82),(83),(84),(85),(86),(87),(88),(89),(90),(91),(92),(93),(94),(95),(96),(97),(98),(99)) __tbl_3) AS __tbl_5) AS __tbl_7, (SELECT __tbl_6.column_0 AS __col_7 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9),(10),(11),(12),(13),(14),(15),(16),(17),(18),(19),(20),(21),(22),(23),(24),(25),(26),(27),(28),(29),(30),(31),(32),(33),(34),(35),(36),(37),(38),(39),(40),(41),(42),(43),(44),(45),(46),(47),(48),(49),(50),(51),(52),(53),(54),(55),(56),(57),(58),(59),(60),(61),(62),(63),(64),(65),(66),(67),(68),(69),(70),(71),(72),(73),(74),(75),(76),(77),(78),(79),(80),(81),(82),(83),(84),(85),(86),(87),(88),(89),(90),(91),(92),(93),(94),(95),(96),(97),(98),(99)) __tbl_6) AS __tbl_8) as __tbl_9;
DROP TABLE if exists seed1;
CREATE TABLE if not exists seed1
(
c INT NOT NULL
) ENGINE=OLAP
DUPLICATE KEY(`c`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`c`) BUCKETS 32
PROPERTIES(
"replication_num" = "1",
"storage_format" = "default"
);
INSERT INTO seed1
  (c)
  select row_number() over() as r from (SELECT __tbl_10.__col_8 AS __col_13, __tbl_10.__col_9 AS __col_14, __tbl_10.__col_10 AS __col_15, __tbl_10.__col_11 AS __col_16, __tbl_11.__col_12 AS __col_17 from (SELECT __tbl_7.__col_4 AS __col_8, __tbl_7.__col_5 AS __col_9, __tbl_7.__col_6 AS __col_10, __tbl_8.__col_7 AS __col_11 from (SELECT __tbl_4.__col_1 AS __col_4, __tbl_4.__col_2 AS __col_5, __tbl_5.__col_3 AS __col_6 from (SELECT __tbl_1.v AS __col_1, __tbl_2.__col_0 AS __col_2 from (select v from (values(0)) t(v)) AS __tbl_1, (SELECT __tbl_0.column_0 AS __col_0 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9)) __tbl_0) AS __tbl_2) AS __tbl_4, (SELECT __tbl_3.column_0 AS __col_3 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9),(10),(11),(12),(13),(14),(15),(16),(17),(18),(19),(20),(21),(22),(23),(24),(25),(26),(27),(28),(29),(30),(31),(32),(33),(34),(35),(36),(37),(38),(39),(40),(41),(42),(43),(44),(45),(46),(47),(48),(49),(50),(51),(52),(53),(54),(55),(56),(57),(58),(59),(60),(61),(62),(63),(64),(65),(66),(67),(68),(69),(70),(71),(72),(73),(74),(75),(76),(77),(78),(79),(80),(81),(82),(83),(84),(85),(86),(87),(88),(89),(90),(91),(92),(93),(94),(95),(96),(97),(98),(99)) __tbl_3) AS __tbl_5) AS __tbl_7, (SELECT __tbl_6.column_0 AS __col_7 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9),(10),(11),(12),(13),(14),(15),(16),(17),(18),(19),(20),(21),(22),(23),(24),(25),(26),(27),(28),(29),(30),(31),(32),(33),(34),(35),(36),(37),(38),(39),(40),(41),(42),(43),(44),(45),(46),(47),(48),(49),(50),(51),(52),(53),(54),(55),(56),(57),(58),(59),(60),(61),(62),(63),(64),(65),(66),(67),(68),(69),(70),(71),(72),(73),(74),(75),(76),(77),(78),(79),(80),(81),(82),(83),(84),(85),(86),(87),(88),(89),(90),(91),(92),(93),(94),(95),(96),(97),(98),(99)) __tbl_6) AS __tbl_8) AS __tbl_10, (SELECT __tbl_9.column_0 AS __col_12 from (VALUES (0),(1),(2),(3),(4),(5),(6),(7),(8),(9),(10),(11),(12),(13),(14),(15),(16),(17),(18),(19),(20),(21),(22),(23),(24),(25),(26),(27),(28),(29),(30),(31),(32),(33),(34),(35),(36),(37),(38),(39),(40),(41),(42),(43),(44),(45),(46),(47),(48),(49),(50),(51),(52),(53),(54),(55),(56),(57),(58),(59),(60),(61),(62),(63),(64),(65),(66),(67),(68),(69),(70),(71),(72),(73),(74),(75),(76),(77),(78),(79),(80),(81),(82),(83),(84),(85),(86),(87),(88),(89),(90),(91),(92),(93),(94),(95),(96),(97),(98),(99)) __tbl_9) AS __tbl_11) as __tbl_12;
INSERT INTO t0
  (dt, c0, c1)
  select to_date(days_add('2023-01-01', cast((rand()+rand())*31/2 as int))) as __col_0, cast((rand()+rand())*100000/2 as int) as __col_1, cast((rand()+rand())*100000/2 as int) as __col_2 from (SELECT c FROM seed0) __tbl_0;
INSERT INTO t1
  (dt, c0, c1)
  select to_date(days_add('2023-01-01', cast((rand()+rand())*365/2 as int))) as __col_3, cast((rand()+rand())*10000000/2 as int) as __col_4, cast((rand()+rand())*10000000/2 as int) as __col_5 from (SELECT c FROM seed1) __tbl_1;
?[1;32m******************** [FINISH] test_pipeline_level_runtime_filter ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf_for_colocate ?[0m
?[1;32m[case file]: sql/test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf/R/test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf_for_colocate ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_9c33bb6ad63d408c88eac8a87f66faab;
[SQL]: USE test_db_9c33bb6ad63d408c88eac8a87f66faab;
	 → case db: ['test_db_9c33bb6ad63d408c88eac8a87f66faab']
	 → case resource: []
CREATE TABLE t1 (
  k1 bigint NULL,
  c1 bigint NULL
) ENGINE=OLAP
DUPLICATE KEY(`k1`)
DISTRIBUTED BY HASH(`k1`) BUCKETS 32
PROPERTIES (
    "replication_num" = "1"
);
?[1;32m******************** [FINISH] test_runtime_filter_push_down_on_local_right_offsprings_of_broadcast_join_with_grf_for_colocate ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_same_correlation_col_in ?[0m
?[1;32m[case file]: sql/test_subquery/R/test_complex_in ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_3b8d06b69a6b477dbc0c8330d1f2df51;
[SQL]: USE test_db_3b8d06b69a6b477dbc0c8330d1f2df51;
	 → case db: ['test_db_3b8d06b69a6b477dbc0c8330d1f2df51']
	 → case resource: []
CREATE TABLE `t0` (
  `v1` bigint(20) NULL COMMENT "",
  `v2` bigint(20) NULL COMMENT "",
  `v3` bigint(20) NULL COMMENT "",
  `v4` largeint NULL COMMENT "",
  `v5` tinyint NULL COMMENT ""
) ENGINE=OLAP
DUPLICATE KEY(`v1`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`v1`) BUCKETS 3
PROPERTIES (
"replication_num" = "1",
"enable_persistent_index" = "false",
"replicated_storage" = "false",
"compression" = "LZ4"
);
?[1;32m******************** [FINISH] test_same_correlation_col_in ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.util.concurrent.ExecutionException: java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_sample_collection ?[0m
?[1;32m[case file]: sql/test_collect_statistics/R/test_sample_collection ?[0m
?[1;32m------------------------------------------------------------ ?[0m
	 → case db: ['test_sample_collection']
	 → case resource: []
create database test_sample_collection;
use test_sample_collection;
create table test_778899(
c0 int not null,
c1 date not null,
c2 varchar(255),
`escape['0']` decimal(10, 2),
c4 struct<a int, b array<struct<a int, b int>>>,
c5 struct<a int, b int>,
c6 struct<a int, b int, c struct<a int, b int>,d array<int>>)
duplicate key(c0)
partition by (c1)
distributed by hash(c0) buckets 200 properties('replication_num'='1');
?[1;32m******************** [FINISH] test_sample_collection ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_schema_change ?[0m
?[1;32m[case file]: sql/test_automatic_partition/R/test_automatic_partition ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_25948aa8321349ff848a9f39b538ad61;
[SQL]: USE test_db_25948aa8321349ff848a9f39b538ad61;
	 → case db: ['test_db_25948aa8321349ff848a9f39b538ad61']
	 → case resource: []
CREATE TABLE ss( event_day DATE, pv BIGINT, cc int) DUPLICATE KEY(event_day) PARTITION BY date_trunc('day', event_day) DISTRIBUTED BY HASH(event_day) BUCKETS 1 PROPERTIES("replication_num" = "1");
?[1;32m******************** [FINISH] test_schema_change ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_schema_change_for_add_optimization ?[0m
?[1;32m[case file]: sql/test_materialized_column/R/test_materialized_column ?[0m
?[1;32m------------------------------------------------------------ ?[0m
	 → case db: ['test_schema_change_for_add_optimization']
	 → case resource: []
CREATE DATABASE test_schema_change_for_add_optimization;
USE test_schema_change_for_add_optimization;
CREATE TABLE t ( id BIGINT NOT NULL,  name BIGINT NOT NULL ) Primary KEY (id) DISTRIBUTED BY HASH(id) BUCKETS 7 PROPERTIES("replication_num" = "1", "replicated_storage" = "true", "fast_schema_evolution" = "true");
?[1;32m******************** [FINISH] test_schema_change_for_add_optimization ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_schema_change_with_sync_mv ?[0m
?[1;32m[case file]: sql/test_schema_change/R/test_schema_change_with_sync_mv ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_884275e2d71042d6b8ad412fca704b3f;
[SQL]: USE test_db_884275e2d71042d6b8ad412fca704b3f;
	 → case db: ['test_db_884275e2d71042d6b8ad412fca704b3f']
	 → case resource: []
CREATE TABLE IF NOT EXISTS t1
(
    `id` bigint(20) NULL,
    `k2` datetime NULL,
    `k3` varchar(32),
    `k4` int(11) NULL,
    `k5` bigint(20),
    `k6` double NULL,
    `k7` varchar(255) NULL
    ) ENGINE = OLAP
    DUPLICATE KEY(id, k2, k3)
    PARTITION BY RANGE(k2)(
    START ("2022-04-17") END ("2022-05-01") EVERY (INTERVAL 1 day))
    DISTRIBUTED BY HASH(id)
    PROPERTIES
(
    "replication_num" = "1",
    "dynamic_partition.enable" = "true",
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.end" = "2",
    "dynamic_partition.prefix" = "p"
);
?[1;32m******************** [FINISH] test_schema_change_with_sync_mv ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_after_truncate_list_partition ?[0m
?[1;32m[case file]: sql/test_list_partition/R/test_select_after_truncate_list_partition ?[0m
?[1;32m------------------------------------------------------------ ?[0m
	 → case db: ['test_select_after_truncate_list_partition_zz1']
	 → case resource: []
create database test_select_after_truncate_list_partition_zz1;
use test_select_after_truncate_list_partition_zz1;
CREATE TABLE IF NOT EXISTS t_ptr_label_ice(
    obj_id string not null COMMENT'客户编号',
    lab_numr string not null COMMENT'标签编号',
    busi_date string not null COMMENT'业务日期',
    lab_val VARCHAR(1048576) COMMENT'值'
)UNIQUE KEY(obj_id, lab_numr, busi_date)
PARTITION BY LIST (lab_numr, busi_date)(
    PARTITION p1 VALUES IN (("lab1", "2022-01-01")),
   PARTITION p2 VALUES IN (("lab3", "2022-01-03")),
   PARTITION p3 VALUES IN (("lab5", "2022-01-07")),
   PARTITION p4 VALUES IN (("lab9", "2022-01-09"))
)
DISTRIBUTED BY HASH(obj_id);
?[1;32m******************** [FINISH] test_select_after_truncate_list_partition ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_async_mv ?[0m
?[1;32m[case file]: sql/test_random_distribution/R/test_random_distribution ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_096b82b4bc414f9880039a06c7ec2994;
[SQL]: USE test_db_096b82b4bc414f9880039a06c7ec2994;
	 → case db: ['test_db_096b82b4bc414f9880039a06c7ec2994']
	 → case resource: []
create table t(k int, v int);
?[1;32m******************** [FINISH] test_select_async_mv ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'Backend node not found. Check if any backend node is down.backend: [172.21.251.135 alive: true inBlacklist: true] [172.21.251.136 alive: true inBlacklist: false] [172.21.251.137 alive: true inBlacklist: false] '))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_be_bvars ?[0m
?[1;32m[case file]: sql/test_information_schema/R/test_be_bvars ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_a16e8d429a19456087db02e6aaa202d7;
[SQL]: USE test_db_a16e8d429a19456087db02e6aaa202d7;
	 → case db: ['test_db_a16e8d429a19456087db02e6aaa202d7']
	 → case resource: []
select * from information_schema.be_bvars where name like '%lake_publish_version_queued%' and value < 0;
?[1;32m******************** [FINISH] test_select_be_bvars ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_from_be_tablets_with_any_priv ?[0m
?[1;32m[case file]: sql/test_rbac/R/test_be_tablets_access_control ?[0m
?[1;32m------------------------------------------------------------ ?[0m
	 → case db: ['test_select_from_be_tablets_with_any_priv_db']
	 → case resource: []
create database test_select_from_be_tablets_with_any_priv_db;
create table test_select_from_be_tablets_with_any_priv_db.test11 (id int) duplicate key (id) distributed by hash(id) buckets 1 properties("replication_num"="1");
?[1;32m******************** [FINISH] test_select_from_be_tablets_with_any_priv ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_into_outfile ?[0m
?[1;32m[case file]: sql/test_sink/R/test_select_into_outfile ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_01c44166779549648b7cb6326124e0e3;
[SQL]: USE test_db_01c44166779549648b7cb6326124e0e3;
	 → case db: ['test_db_01c44166779549648b7cb6326124e0e3']
	 → case resource: []
create table t1 (c1 int, c2 binary);
?[1;32m******************** [FINISH] test_select_into_outfile ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_into_outfile_csv_inconsistent_converter_and_column ?[0m
?[1;32m[case file]: sql/test_sink/R/test_select_into_outfile_csv_inconsistent_converter_and_column ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_0e54c38af7de42c289a31235e3a228c1;
[SQL]: USE test_db_0e54c38af7de42c289a31235e3a228c1;
	 → case db: ['test_db_0e54c38af7de42c289a31235e3a228c1']
	 → case resource: []
create table t1 (k1 int, k2 int, k3 int) distributed by hash(k1) buckets 1;
?[1;32m******************** [FINISH] test_select_into_outfile_csv_inconsistent_converter_and_column ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_select_out_file ?[0m
?[1;32m[case file]: sql/test_temporary_table/R/temporary_table ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_48c292873f1a4dae941d9c36b7df95a8;
[SQL]: USE test_db_48c292873f1a4dae941d9c36b7df95a8;
	 → case db: ['test_db_48c292873f1a4dae941d9c36b7df95a8']
	 → case resource: []
create temporary table `t` (
    `c1` int,
    `c2` int
) engine=OLAP primary key(`c1`) distributed by hash(`c1`) buckets 3 properties("replication_num" = "1");
?[1;32m******************** [FINISH] test_select_out_file ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_serialize_key_agg ?[0m
?[1;32m[case file]: sql/test_agg/R/test_serialize_key_agg ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_f02cdf9091704d4ea50bcc2269b76cf7;
[SQL]: USE test_db_f02cdf9091704d4ea50bcc2269b76cf7;
	 → case db: ['test_db_f02cdf9091704d4ea50bcc2269b76cf7']
	 → case resource: []
create table t0 (
    c0 STRING,
    c1 STRING,
    c2 STRING
) DUPLICATE KEY(c0) DISTRIBUTED BY HASH(c0) BUCKETS 3 PROPERTIES('replication_num' = '1');
?[1;32m******************** [FINISH] test_serialize_key_agg ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_set_partition_version ?[0m
?[1;32m[case file]: sql/test_recovery/R/test_recovery ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_06b5737fbec04f1d93eb8cf6ef32f68a;
[SQL]: USE test_db_06b5737fbec04f1d93eb8cf6ef32f68a;
	 → case db: ['test_db_06b5737fbec04f1d93eb8cf6ef32f68a']
	 → case resource: []
CREATE TABLE t (a int);
?[1;32m******************** [FINISH] test_set_partition_version ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_short_circuit ?[0m
?[1;32m[case file]: sql/test_spill/R/test_short_circuit ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_d4136d34795d44f4a9e017f26d9d12db;
[SQL]: USE test_db_d4136d34795d44f4a9e017f26d9d12db;
	 → case db: ['test_db_d4136d34795d44f4a9e017f26d9d12db']
	 → case resource: []
set enable_spill=true;
set spill_mode="force";
set pipeline_dop=1;
create table t0 (
    c0 INT,
    c1 BIGINT
) DUPLICATE KEY(c0) DISTRIBUTED BY HASH(c0) BUCKETS 4 PROPERTIES('replication_num' = '1');
?[1;32m******************** [FINISH] test_short_circuit ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_short_circuit_unique ?[0m
?[1;32m[case file]: sql/test_spill/R/test_short_circuit_unique ?[0m
?[1;32m------------------------------------------------------------ ?[0m
[SQL]: CREATE DATABASE test_db_8395073f69954ecea36ba56150d216c7;
[SQL]: USE test_db_8395073f69954ecea36ba56150d216c7;
	 → case db: ['test_db_8395073f69954ecea36ba56150d216c7']
	 → case resource: []
create table unique_tbl(a int, b string) 
unique key(a)
distributed by hash(a)
PROPERTIES('replication_num' = '1');
?[1;32m******************** [FINISH] test_short_circuit_unique ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_show_column ?[0m
?[1;32m[case file]: sql/test_show/R/test_show_column ?[0m
?[1;32m------------------------------------------------------------ ?[0m
	 → case db: ['test_show1', 'test_show2']
	 → case resource: []
create database test_show1;
create database test_show2;
use test_show1;
CREATE TABLE site_access(
    event_day DATE,
    site_id INT DEFAULT '10',
    city_code VARCHAR(100),
    user_name VARCHAR(32) DEFAULT '',
    pv BIGINT SUM DEFAULT '0'
)
DISTRIBUTED BY HASH(site_id)
PROPERTIES (
  "replication_num" = "1"
);
?[1;32m******************** [FINISH] test_show_column ******************** ?[0m

[Stacktrace]: 
Traceback (most recent call last):
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 60, in testPartExecutor
    yield
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 676, in run
    self._callTestMethod(testMethod)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 633, in _callTestMethod
    method()
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/nose/case.py", line 170, in runTest
    self.test(*self.arg)
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/site-packages/parameterized/parameterized.py", line 620, in standalone_func
    return func(*(a + p.args), **p.kwargs, **kw)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 48, in wrapper
    raise e
  File "/home/runner/_work/starrocks/starrocks/test/lib/sql_annotation.py", line 43, in wrapper
    res = func(*args, **kwargs)
  File "/home/runner/_work/starrocks/starrocks/test/test_sql_cases.py", line 384, in test_sql_basic
    self.check(sql_id, sql, expect_res, actual_res, order, ori_sql)
  File "/home/runner/_work/starrocks/starrocks/test/lib/sr_sql_lib.py", line 1336, in check
    tools.assert_false(str(act).startswith("E: "), "sql result not match: actual with E(%s)" % str(act))
  File "/root/.pyenv/versions/3.8.19/lib/python3.8/unittest/case.py", line 759, in assertFalse
    raise self.failureException(msg)
AssertionError: True is not false : sql result not match: actual with E(E: (1064, 'java.lang.RuntimeException: org.apache.thrift.TException: java.net.ConnectException: Connection refused (Connection refused)'))

[Standard Output]: 
?[1;32m------------------------------------------------------------ ?[0m
?[1;32m[case name]: test_show_create_routine_load_basic ?[0m
?[1;32m[case file]: sql/test_routine_load/R/test_show_create_routine_load ?[0m
?[1;32m------------------------------------------------------------ ?[0m
	 → case db: ['test_show_create_routine_load']
	 → case resource: []
create database test_show_create_routine_load;
use test_show_create_routine_load;
create table herbavro (
	advertiser_id int not null,
    advertiser_ad_type int not null,
    advertiser_ad_width int not null,
    advertiser_currency_type varchar(60) not null,
    event_day DATE
)
DUPLICATE KEY(advertiser_id) COMMENT "OLAP" 
PARTITION BY RANGE (event_day) (
    PARTITION p1 VALUES LESS THAN ("2020-01-31"),
    PARTITION p2 VALUES LESS THAN ("2020-02-29"),
    PARTITION p3 VALUES LESS THAN ("2030-03-31")
)
DISTRIBUTED BY HASH(advertiser_id) BUCKETS 3 
PROPERTIES ( "replication_num" = "1", "storage_format" = "v2" );
?[1;32m******************** [FINISH] test_show_create_routine_load_basic ******************** ?[0m