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 1789e2a314e Remove slow auto analyze test case. (#31037)
1789e2a314e is described below
commit 1789e2a314eae979c6eed2850778ba84170b4297
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Sun Feb 18 13:44:06 2024 +0800
Remove slow auto analyze test case. (#31037)
---
.../suites/statistics/test_analyze_mv.groovy | 25 ++++++++--------------
1 file changed, 9 insertions(+), 16 deletions(-)
diff --git a/regression-test/suites/statistics/test_analyze_mv.groovy
b/regression-test/suites/statistics/test_analyze_mv.groovy
index 863f54b5de5..3a29cafafbd 100644
--- a/regression-test/suites/statistics/test_analyze_mv.groovy
+++ b/regression-test/suites/statistics/test_analyze_mv.groovy
@@ -52,12 +52,12 @@ suite("test_analyze_mv") {
}
}
- def wait_auto_analyze_finish = { table ->
+ def wait_analyze_finish = { table ->
while(true) {
Thread.sleep(1000)
boolean finished = true;
- def result = sql """SHOW AUTO ANALYZE ${table};"""
- logger.info("wait auto analyze finish: " + result)
+ def result = sql """SHOW ANALYZE ${table};"""
+ logger.info("wait analyze finish: " + result)
if (result.size() <= 0) {
logger.info("Not analyzed yet.")
continue;
@@ -271,8 +271,6 @@ suite("test_analyze_mv") {
wait_mv_finish("test_analyze_mv", "mvTestUni")
sql """insert into mvTestUni values (1, 2, 3, 4, 5), (1, 2, 3, 7, 8), (1,
11, 22, 33, 44), (10, 20, 30, 40, 50), (10, 20, 30, 40, 50), (100, 200, 300,
400, 500), (1001, 2001, 3001, 4001, 5001);"""
- sql """analyze table mvTestUni with sync;"""
-
sql """analyze table mvTestUni with sync;"""
result_sample = sql """show column stats mvTestUni"""
assertEquals(9, result_sample.size())
@@ -311,13 +309,14 @@ suite("test_analyze_mv") {
sql """drop stats mvTestDup"""
result_sample = sql """show column stats mvTestDup"""
assertEquals(0, result_sample.size())
- sql """analyze database test_analyze_mv
PROPERTIES("use.auto.analyzer"="true")"""
- wait_auto_analyze_finish("mvTestDup")
- result_sample = sql """SHOW AUTO ANALYZE mvTestDup;"""
- logger.info("show auto analyze result: " + result_sample)
+ // Test sample
+ sql """analyze table mvTestDup with sample rows 4000000"""
+ wait_analyze_finish("mvTestDup")
+ result_sample = sql """SHOW ANALYZE mvTestDup;"""
+ logger.info("show analyze result: " + result_sample)
def jobId = result_sample[result_sample.size() - 1][0]
- logger.info("Auto analyze job id is " + jobId)
+ logger.info("Analyze job id is " + jobId)
result_sample = sql """show column stats mvTestDup"""
assertEquals(12, result_sample.size())
@@ -331,7 +330,6 @@ suite("test_analyze_mv") {
assertEquals("1", result_sample[0][7])
assertEquals("1001", result_sample[0][8])
assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("SYSTEM", result_sample[0][11])
result_sample = sql """show column stats mvTestDup(value1)"""
assertEquals(1, result_sample.size())
@@ -342,7 +340,6 @@ suite("test_analyze_mv") {
assertEquals("3", result_sample[0][7])
assertEquals("3001", result_sample[0][8])
assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("SYSTEM", result_sample[0][11])
result_sample = sql """show column stats mvTestDup(mv_key1)"""
assertEquals(2, result_sample.size())
@@ -357,7 +354,6 @@ suite("test_analyze_mv") {
assertEquals("1", result_sample[0][7])
assertEquals("1001", result_sample[0][8])
assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("SYSTEM", result_sample[0][11])
result_sample = sql """show column stats
mvTestDup(`mva_SUM__CAST(``value1`` AS BIGINT)`)"""
assertEquals(1, result_sample.size())
@@ -368,7 +364,6 @@ suite("test_analyze_mv") {
assertEquals("6", result_sample[0][7])
assertEquals("3001", result_sample[0][8])
assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("SYSTEM", result_sample[0][11])
result_sample = sql """show column stats
mvTestDup(`mva_MAX__``value2```)"""
assertEquals(1, result_sample.size())
@@ -379,7 +374,6 @@ suite("test_analyze_mv") {
assertEquals("4", result_sample[0][7])
assertEquals("4001", result_sample[0][8])
assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("SYSTEM", result_sample[0][11])
result_sample = sql """show column stats
mvTestDup(`mva_MIN__``value3```)"""
assertEquals(1, result_sample.size())
@@ -390,7 +384,6 @@ suite("test_analyze_mv") {
assertEquals("5", result_sample[0][7])
assertEquals("5001", result_sample[0][8])
assertEquals("SAMPLE", result_sample[0][9])
- assertEquals("SYSTEM", result_sample[0][11])
result_sample = sql """show analyze task status ${jobId}"""
assertEquals(12, result_sample.size())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
