@@ -24,6 +24,7 @@ suite("test_analyze") {
24
24
String tbl = " analyzetestlimited_duplicate_all"
25
25
26
26
sql """ set global force_sample_analyze=false"""
27
+ sql """ set global enable_auto_analyze=false"""
27
28
sql """
28
29
DROP DATABASE IF EXISTS `${ db} `
29
30
"""
@@ -164,14 +165,30 @@ suite("test_analyze") {
164
165
exception = e
165
166
}
166
167
168
+ // Test sample agg table value column. Min max is N/A when zone map is not available.
169
+ sql """
170
+ CREATE TABLE `agg_table_test` (
171
+ `id` BIGINT NOT NULL,
172
+ `name` VARCHAR(10) REPLACE NULL
173
+ ) ENGINE=OLAP
174
+ AGGREGATE KEY(`id`)
175
+ COMMENT 'OLAP'
176
+ DISTRIBUTED BY HASH(`id`) BUCKETS 32
177
+ PROPERTIES (
178
+ "replication_num" = "1"
179
+ );
180
+ """
181
+ sql """ insert into agg_table_test values (1,'name1'), (2, 'name2')"""
182
+ sql """ analyze table agg_table_test with sample rows 100 with sync"""
183
+ def agg_result = sql """ show column stats agg_table_test (name)"""
184
+ logger. info(" show column agg_table_test(name) stats: " + agg_result)
185
+ assertEquals (agg_result[0 ][7 ], " N/A" )
186
+ assertEquals (agg_result[0 ][8 ], " N/A" )
187
+
167
188
def a_result_1 = sql """
168
189
ANALYZE DATABASE ${ db} WITH SYNC WITH SAMPLE PERCENT 10
169
190
"""
170
191
171
- def a_result_2 = sql """
172
- ANALYZE DATABASE ${ db} WITH SYNC WITH SAMPLE PERCENT 5
173
- """
174
-
175
192
def a_result_3 = sql """
176
193
ANALYZE DATABASE ${ db} WITH SAMPLE PERCENT 5
177
194
"""
@@ -1149,24 +1166,14 @@ PARTITION `p599` VALUES IN (599)
1149
1166
sql """ ANALYZE TABLE test_updated_rows WITH SYNC"""
1150
1167
sql """ INSERT INTO test_updated_rows VALUES('1',1,1); """
1151
1168
def cnt1 = sql """ SHOW TABLE STATS test_updated_rows """
1152
- for (int i = 0 ; i < 10 ; ++ i) {
1153
- if (Integer . valueOf(cnt1[0 ][0 ]) == 8 ) break ;
1154
- Thread . sleep(1000 ) // rows updated report is async
1155
- cnt1 = sql """ SHOW TABLE STATS test_updated_rows """
1156
- }
1157
1169
assertEquals (Integer . valueOf(cnt1[0 ][0 ]), 1 )
1158
1170
sql """ ANALYZE TABLE test_updated_rows WITH SYNC"""
1159
1171
sql """ INSERT INTO test_updated_rows SELECT * FROM test_updated_rows """
1160
1172
sql """ INSERT INTO test_updated_rows SELECT * FROM test_updated_rows """
1161
1173
sql """ INSERT INTO test_updated_rows SELECT * FROM test_updated_rows """
1162
1174
sql """ ANALYZE TABLE test_updated_rows WITH SYNC"""
1163
1175
def cnt2 = sql """ SHOW TABLE STATS test_updated_rows """
1164
- for (int i = 0 ; i < 10 ; ++ i) {
1165
- if (Integer . valueOf(cnt2[0 ][0 ]) == 8 ) break ;
1166
- Thread . sleep(1000 ) // rows updated report is async
1167
- cnt2 = sql """ SHOW TABLE STATS test_updated_rows """
1168
- }
1169
- assertTrue (Integer . valueOf(cnt2[0 ][0 ]) == 0 || Integer . valueOf(cnt2[0 ][0 ]) == 8 )
1176
+ assertEquals (Integer . valueOf(cnt2[0 ][0 ]), 8 )
1170
1177
1171
1178
// test analyze specific column
1172
1179
sql """ CREATE TABLE test_analyze_specific_column (col1 varchar(11451) not null, col2 int not null, col3 int not null)
@@ -2625,27 +2632,6 @@ PARTITION `p599` VALUES IN (599)
2625
2632
partition_result = sql """ show table stats partition_test"""
2626
2633
assertEquals (partition_result[0 ][6 ], " false" )
2627
2634
2628
- // Test sample agg table value column
2629
- sql """
2630
- CREATE TABLE `agg_table_test` (
2631
- `id` BIGINT NOT NULL,
2632
- `name` VARCHAR(10) REPLACE NULL
2633
- ) ENGINE=OLAP
2634
- AGGREGATE KEY(`id`)
2635
- COMMENT 'OLAP'
2636
- DISTRIBUTED BY HASH(`id`) BUCKETS 32
2637
- PROPERTIES (
2638
- "replication_num" = "1"
2639
- );
2640
- """
2641
- sql """ insert into agg_table_test values (1,'name1'), (2, 'name2')"""
2642
- Thread . sleep(1000 * 60 )
2643
- sql """ analyze table agg_table_test with sample rows 100 with sync"""
2644
- def agg_result = sql """ show column stats agg_table_test (name)"""
2645
- logger. info(" show column agg_table_test(name) stats: " + agg_result)
2646
- assertEquals (agg_result[0 ][7 ], " N/A" )
2647
- assertEquals (agg_result[0 ][8 ], " N/A" )
2648
-
2649
2635
// Test sample string type min max
2650
2636
sql """
2651
2637
CREATE TABLE `string_min_max` (
0 commit comments