This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new a831aabac49 [fix](regression)Disable auto analyze before running mtmv
test. (#36449)
a831aabac49 is described below
commit a831aabac493195d0048eaf8c0b21c77bb8bd674
Author: Jibing-Li <[email protected]>
AuthorDate: Tue Jun 18 14:52:18 2024 +0800
[fix](regression)Disable auto analyze before running mtmv test. (#36449)
Disable auto analyze before running mtmv test. Because auto analyze
result may overwrite manual analyze result.
---
.../suites/statistics/test_analyze_mtmv.groovy | 860 +++++++++++----------
1 file changed, 432 insertions(+), 428 deletions(-)
diff --git a/regression-test/suites/statistics/test_analyze_mtmv.groovy
b/regression-test/suites/statistics/test_analyze_mtmv.groovy
index 7e71b72002c..72f4355c41d 100644
--- a/regression-test/suites/statistics/test_analyze_mtmv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mtmv.groovy
@@ -52,458 +52,462 @@ suite("test_analyze_mtmv") {
sql """create database test_analyze_mtmv"""
sql """use test_analyze_mtmv"""
sql """set global force_sample_analyze=false"""
-
- sql """CREATE TABLE IF NOT EXISTS orders (
- o_orderkey integer not null,
- o_custkey integer not null,
- o_orderstatus char(1) not null,
- o_totalprice decimalv3(15,2) not null,
- o_orderdate date not null,
- o_orderpriority char(15) not null,
- o_clerk char(15) not null,
- o_shippriority integer not null,
- o_comment varchar(79) not null
- )
- DUPLICATE KEY(o_orderkey, o_custkey)
- PARTITION BY RANGE(o_orderdate)(
- FROM ('2023-10-17') TO ('2023-10-20') INTERVAL 1 DAY)
- DISTRIBUTED BY HASH(o_orderkey) BUCKETS 3
- PROPERTIES ("replication_num" = "1");
- """
-
- sql """insert into orders values
- (1, 1, 'ok', 99.5, '2023-10-17', 'a', 'b', 1, 'yy'),
- (2, 2, 'ok', 109.2, '2023-10-18', 'c','d',2, 'mm'),
- (3, 3, 'ok', 99.5, '2023-10-19', 'a', 'b', 1, 'yy');
- """
-
- sql """CREATE TABLE IF NOT EXISTS lineitem (
- l_orderkey integer not null,
- l_partkey integer not null,
- l_suppkey integer not null,
- l_linenumber integer not null,
- l_quantity decimalv3(15,2) not null,
- l_extendedprice decimalv3(15,2) not null,
- l_discount decimalv3(15,2) not null,
- l_tax decimalv3(15,2) not null,
- l_returnflag char(1) not null,
- l_linestatus char(1) not null,
- l_shipdate date not null,
- l_commitdate date not null,
- l_receiptdate date not null,
- l_shipinstruct char(25) not null,
- l_shipmode char(10) not null,
- l_comment varchar(44) not null
- )
- DUPLICATE KEY(l_orderkey, l_partkey, l_suppkey, l_linenumber)
- PARTITION BY RANGE(l_shipdate)
- (FROM ('2023-10-17') TO ('2023-10-20') INTERVAL 1 DAY)
- DISTRIBUTED BY HASH(l_orderkey) BUCKETS 3
- PROPERTIES ("replication_num" = "1");
- """
-
- sql """insert into lineitem values
- (1, 2, 3, 4, 5.5, 6.5, 7.5, 8.5, 'o', 'k', '2023-10-17',
'2023-10-17', '2023-10-17', 'a', 'b', 'yyyyyyyyy'),
- (2, 2, 3, 4, 5.5, 6.5, 7.5, 8.5, 'o', 'k', '2023-10-18',
'2023-10-18', '2023-10-18', 'a', 'b', 'yyyyyyyyy'),
- (3, 2, 3, 6, 7.5, 8.5, 9.5, 10.5, 'k', 'o', '2023-10-19',
'2023-10-19', '2023-10-19', 'c', 'd', 'xxxxxxxxx');
- """
-
- sql """
- CREATE MATERIALIZED VIEW mv1
- BUILD DEFERRED REFRESH AUTO ON MANUAL
- partition by(l_shipdate)
- DISTRIBUTED BY RANDOM BUCKETS 2
- PROPERTIES ('replication_num' = '1')
- AS
- select l_shipdate, o_orderdate, l_partkey, l_suppkey,
sum(o_totalprice) as sum_total
- from lineitem
- left join orders on lineitem.l_orderkey =
orders.o_orderkey and l_shipdate = o_orderdate
- group by
- l_shipdate,
- o_orderdate,
- l_partkey,
- l_suppkey;
- """
- sql """REFRESH MATERIALIZED VIEW mv1 AUTO"""
- while(true) {
- Thread.sleep(1000)
- def result = sql """select * from
mv_infos("database"="test_analyze_mtmv") where Name="mv1";"""
- if (result[0][5] == "SUCCESS") {
- break;
+ try {
+ sql """set global enable_auto_analyze=false"""
+ sql """CREATE TABLE IF NOT EXISTS orders (
+ o_orderkey integer not null,
+ o_custkey integer not null,
+ o_orderstatus char(1) not null,
+ o_totalprice decimalv3(15,2) not null,
+ o_orderdate date not null,
+ o_orderpriority char(15) not null,
+ o_clerk char(15) not null,
+ o_shippriority integer not null,
+ o_comment varchar(79) not null
+ )
+ DUPLICATE KEY(o_orderkey, o_custkey)
+ PARTITION BY RANGE(o_orderdate)(
+ FROM ('2023-10-17') TO ('2023-10-20') INTERVAL 1 DAY)
+ DISTRIBUTED BY HASH(o_orderkey) BUCKETS 3
+ PROPERTIES ("replication_num" = "1");
+ """
+
+ sql """insert into orders values
+ (1, 1, 'ok', 99.5, '2023-10-17', 'a', 'b', 1, 'yy'),
+ (2, 2, 'ok', 109.2, '2023-10-18', 'c','d',2, 'mm'),
+ (3, 3, 'ok', 99.5, '2023-10-19', 'a', 'b', 1, 'yy');
+ """
+
+ sql """CREATE TABLE IF NOT EXISTS lineitem (
+ l_orderkey integer not null,
+ l_partkey integer not null,
+ l_suppkey integer not null,
+ l_linenumber integer not null,
+ l_quantity decimalv3(15,2) not null,
+ l_extendedprice decimalv3(15,2) not null,
+ l_discount decimalv3(15,2) not null,
+ l_tax decimalv3(15,2) not null,
+ l_returnflag char(1) not null,
+ l_linestatus char(1) not null,
+ l_shipdate date not null,
+ l_commitdate date not null,
+ l_receiptdate date not null,
+ l_shipinstruct char(25) not null,
+ l_shipmode char(10) not null,
+ l_comment varchar(44) not null
+ )
+ DUPLICATE KEY(l_orderkey, l_partkey, l_suppkey, l_linenumber)
+ PARTITION BY RANGE(l_shipdate)
+ (FROM ('2023-10-17') TO ('2023-10-20') INTERVAL 1 DAY)
+ DISTRIBUTED BY HASH(l_orderkey) BUCKETS 3
+ PROPERTIES ("replication_num" = "1");
+ """
+
+ sql """insert into lineitem values
+ (1, 2, 3, 4, 5.5, 6.5, 7.5, 8.5, 'o', 'k', '2023-10-17',
'2023-10-17', '2023-10-17', 'a', 'b', 'yyyyyyyyy'),
+ (2, 2, 3, 4, 5.5, 6.5, 7.5, 8.5, 'o', 'k', '2023-10-18',
'2023-10-18', '2023-10-18', 'a', 'b', 'yyyyyyyyy'),
+ (3, 2, 3, 6, 7.5, 8.5, 9.5, 10.5, 'k', 'o', '2023-10-19',
'2023-10-19', '2023-10-19', 'c', 'd', 'xxxxxxxxx');
+ """
+
+ sql """
+ CREATE MATERIALIZED VIEW mv1
+ BUILD DEFERRED REFRESH AUTO ON MANUAL
+ partition by(l_shipdate)
+ DISTRIBUTED BY RANDOM BUCKETS 2
+ PROPERTIES ('replication_num' = '1')
+ AS
+ select l_shipdate, o_orderdate, l_partkey, l_suppkey,
sum(o_totalprice) as sum_total
+ from lineitem
+ left join orders on lineitem.l_orderkey =
orders.o_orderkey and l_shipdate = o_orderdate
+ group by
+ l_shipdate,
+ o_orderdate,
+ l_partkey,
+ l_suppkey;
+ """
+ sql """REFRESH MATERIALIZED VIEW mv1 AUTO"""
+ while(true) {
+ Thread.sleep(1000)
+ def result = sql """select * from
mv_infos("database"="test_analyze_mtmv") where Name="mv1";"""
+ if (result[0][5] == "SUCCESS") {
+ break;
+ }
}
- }
- def dup_sql1 = """select * from mv1 order by l_shipdate;"""
- qt_sql1 dup_sql1
-
- sql """analyze table mv1 with sync"""
-
- def result_sample = sql """show column stats mv1"""
- assertEquals(5, result_sample.size())
-
- result_sample = sql """show column stats mv1(l_shipdate)"""
- assertEquals(1, result_sample.size())
- assertEquals("l_shipdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(l_shipdate)"""
- assertEquals(1, result_sample.size())
- assertEquals("l_shipdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(o_orderdate)"""
- assertEquals(1, result_sample.size())
- assertEquals("o_orderdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(o_orderdate)"""
- assertEquals(1, result_sample.size())
- assertEquals("o_orderdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(l_partkey)"""
- assertEquals(1, result_sample.size())
- assertEquals("l_partkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("2", result_sample[0][7])
- assertEquals("2", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(l_partkey)"""
- assertEquals(1, result_sample.size())
- assertEquals("l_partkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("2", result_sample[0][7])
- assertEquals("2", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(l_suppkey)"""
- assertEquals(1, result_sample.size())
- assertEquals("l_suppkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("3", result_sample[0][7])
- assertEquals("3", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(l_suppkey)"""
- assertEquals(1, result_sample.size())
- assertEquals("l_suppkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("3", result_sample[0][7])
- assertEquals("3", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(sum_total)"""
- assertEquals(1, result_sample.size())
- assertEquals("sum_total", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("2.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("48.0", result_sample[0][5])
- assertEquals("16.0", result_sample[0][6])
- assertEquals("99.50", result_sample[0][7])
- assertEquals("109.20", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(sum_total)"""
- assertEquals(1, result_sample.size())
- assertEquals("sum_total", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("2.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("48.0", result_sample[0][5])
- assertEquals("16.0", result_sample[0][6])
- assertEquals("99.50", result_sample[0][7])
- assertEquals("109.20", result_sample[0][8])
- assertEquals("FULL", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- sql """drop stats mv1"""
- result_sample = sql """show column stats mv1(sum_total)"""
- assertEquals(0, result_sample.size())
- result_sample = sql """show column cached stats mv1(sum_total)"""
- assertEquals(0, result_sample.size())
+ def dup_sql1 = """select * from mv1 order by l_shipdate;"""
+ qt_sql1 dup_sql1
- try {
- wait_row_count_reported("test_analyze_mtmv", "mv1", 0, 4, "3")
- } catch (Exception e) {
- logger.info(e.getMessage());
- return;
- }
- sql """analyze table mv1 with sync with sample rows 4000000"""
- result_sample = sql """show column stats mv1(l_shipdate)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync"""
+
+ def result_sample = sql """show column stats mv1"""
+ assertEquals(5, result_sample.size())
+
+ result_sample = sql """show column stats mv1(l_shipdate)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("l_shipdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column cached stats mv1(l_shipdate)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("l_shipdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column stats mv1(o_orderdate)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("o_orderdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column cached stats mv1(o_orderdate)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("o_orderdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column stats mv1(l_partkey)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("l_partkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("2", result_sample[0][7])
+ assertEquals("2", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column cached stats mv1(l_partkey)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("l_partkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("2", result_sample[0][7])
+ assertEquals("2", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column stats mv1(l_suppkey)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("l_suppkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("3", result_sample[0][7])
+ assertEquals("3", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column cached stats mv1(l_suppkey)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("l_suppkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("3", result_sample[0][7])
+ assertEquals("3", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column stats mv1(sum_total)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("sum_total", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("2.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("48.0", result_sample[0][5])
+ assertEquals("16.0", result_sample[0][6])
+ assertEquals("99.50", result_sample[0][7])
+ assertEquals("109.20", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ result_sample = sql """show column cached stats mv1(sum_total)"""
+ assertEquals(1, result_sample.size())
+ assertEquals("sum_total", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("2.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("48.0", result_sample[0][5])
+ assertEquals("16.0", result_sample[0][6])
+ assertEquals("99.50", result_sample[0][7])
+ assertEquals("109.20", result_sample[0][8])
+ assertEquals("FULL", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ sql """drop stats mv1"""
+ result_sample = sql """show column stats mv1(sum_total)"""
+ assertEquals(0, result_sample.size())
+ result_sample = sql """show column cached stats mv1(sum_total)"""
+ assertEquals(0, result_sample.size())
+
+ try {
+ wait_row_count_reported("test_analyze_mtmv", "mv1", 0, 4, "3")
+ } catch (Exception e) {
+ logger.info(e.getMessage());
+ return;
+ }
sql """analyze table mv1 with sync with sample rows 4000000"""
result_sample = sql """show column stats mv1(l_shipdate)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("l_shipdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(l_shipdate)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column stats mv1(l_shipdate)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("l_shipdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column cached stats mv1(l_shipdate)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("l_shipdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(o_orderdate)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column cached stats mv1(l_shipdate)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("l_shipdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column stats mv1(o_orderdate)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("o_orderdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(o_orderdate)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column stats mv1(o_orderdate)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("o_orderdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column cached stats mv1(o_orderdate)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("o_orderdate", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("3.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("'2023-10-17'", result_sample[0][7])
- assertEquals("'2023-10-19'", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(l_partkey)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column cached stats mv1(o_orderdate)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("o_orderdate", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("3.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("'2023-10-17'", result_sample[0][7])
+ assertEquals("'2023-10-19'", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column stats mv1(l_partkey)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("l_partkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("2", result_sample[0][7])
- assertEquals("2", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(l_partkey)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column stats mv1(l_partkey)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("l_partkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("2", result_sample[0][7])
+ assertEquals("2", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column cached stats mv1(l_partkey)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("l_partkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("2", result_sample[0][7])
- assertEquals("2", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(l_suppkey)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column cached stats mv1(l_partkey)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("l_partkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("2", result_sample[0][7])
+ assertEquals("2", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column stats mv1(l_suppkey)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("l_suppkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("3", result_sample[0][7])
- assertEquals("3", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(l_suppkey)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column stats mv1(l_suppkey)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("l_suppkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("3", result_sample[0][7])
+ assertEquals("3", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column cached stats mv1(l_suppkey)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("l_suppkey", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("1.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("12.0", result_sample[0][5])
- assertEquals("4.0", result_sample[0][6])
- assertEquals("3", result_sample[0][7])
- assertEquals("3", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column stats mv1(sum_total)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column cached stats mv1(l_suppkey)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("l_suppkey", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("1.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("12.0", result_sample[0][5])
+ assertEquals("4.0", result_sample[0][6])
+ assertEquals("3", result_sample[0][7])
+ assertEquals("3", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column stats mv1(sum_total)"""
logger.info("result " + result_sample)
- }
- assertEquals(1, result_sample.size())
- assertEquals("sum_total", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("2.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("48.0", result_sample[0][5])
- assertEquals("16.0", result_sample[0][6])
- assertEquals("99.50", result_sample[0][7])
- assertEquals("109.20", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- result_sample = sql """show column cached stats mv1(sum_total)"""
- logger.info("result " + result_sample)
- if ("MANUAL" != result_sample[0][11]) {
- logger.info("Overwrite by auto analyze, analyze it again.")
- sql """analyze table mv1 with sync with sample rows 4000000"""
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column stats mv1(sum_total)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("sum_total", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("2.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("48.0", result_sample[0][5])
+ assertEquals("16.0", result_sample[0][6])
+ assertEquals("99.50", result_sample[0][7])
+ assertEquals("109.20", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
result_sample = sql """show column cached stats mv1(sum_total)"""
logger.info("result " + result_sample)
+ if ("MANUAL" != result_sample[0][11]) {
+ logger.info("Overwrite by auto analyze, analyze it again.")
+ sql """analyze table mv1 with sync with sample rows 4000000"""
+ result_sample = sql """show column cached stats mv1(sum_total)"""
+ logger.info("result " + result_sample)
+ }
+ assertEquals(1, result_sample.size())
+ assertEquals("sum_total", result_sample[0][0])
+ assertEquals("mv1", result_sample[0][1])
+ assertEquals("3.0", result_sample[0][2])
+ assertEquals("2.0", result_sample[0][3])
+ assertEquals("0.0", result_sample[0][4])
+ assertEquals("48.0", result_sample[0][5])
+ assertEquals("16.0", result_sample[0][6])
+ assertEquals("99.50", result_sample[0][7])
+ assertEquals("109.20", result_sample[0][8])
+ assertEquals("SAMPLE", result_sample[0][9])
+ assertEquals("MANUAL", result_sample[0][11])
+
+ sql """drop database if exists test_analyze_mtmv"""
+ } finally {
+ sql """set global enable_auto_analyze=true"""
}
- assertEquals(1, result_sample.size())
- assertEquals("sum_total", result_sample[0][0])
- assertEquals("mv1", result_sample[0][1])
- assertEquals("3.0", result_sample[0][2])
- assertEquals("2.0", result_sample[0][3])
- assertEquals("0.0", result_sample[0][4])
- assertEquals("48.0", result_sample[0][5])
- assertEquals("16.0", result_sample[0][6])
- assertEquals("99.50", result_sample[0][7])
- assertEquals("109.20", result_sample[0][8])
- assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("MANUAL", result_sample[0][11])
-
- sql """drop database if exists test_analyze_mtmv"""
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
