This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 1b783aaa7f55a694a05775b1d6fbd7bbae80a05d
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Fri Mar 8 09:56:33 2024 +0800
[fix](p2)Fix analyze hive partition column p2 case after row count change.
#31958
---
.../hive/test_hive_partition_column_analyze.groovy | 276 ++++++++++-----------
1 file changed, 138 insertions(+), 138 deletions(-)
diff --git
a/regression-test/suites/external_table_p2/hive/test_hive_partition_column_analyze.groovy
b/regression-test/suites/external_table_p2/hive/test_hive_partition_column_analyze.groovy
index eb8a80a7118..336e2e8b784 100644
---
a/regression-test/suites/external_table_p2/hive/test_hive_partition_column_analyze.groovy
+++
b/regression-test/suites/external_table_p2/hive/test_hive_partition_column_analyze.groovy
@@ -39,26 +39,26 @@ suite("test_hive_partition_column_analyze",
"p2,external,hive,external_remote,ex
logger.info("switched to catalog " + catalog_name)
sql """use multi_partition;"""
def result = sql """show column stats multi_partition_parquet
(event_day)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "event_day")
- assertTrue(result[0][2] == "3.83714205E8")
- assertTrue(result[0][3] == "99949.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "3.83714205E9")
- assertTrue(result[0][6] == "10.0")
- assertTrue(result[0][7] == "\'1749-09-24\'")
- assertTrue(result[0][8] == "\'2023-05-26\'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "event_day")
+ assertEquals(result[0][2], "3.83714205E8")
+ assertEquals(result[0][3], "99949.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "3.83714205E9")
+ assertEquals(result[0][6], "10.0")
+ assertEquals(result[0][7], "\'1749-09-24\'")
+ assertEquals(result[0][8], "\'2023-05-26\'")
result = sql """show column stats multi_partition_orc (event_day)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "event_day")
- assertTrue(result[0][2] == "1.9007155E8")
- assertTrue(result[0][3] == "99949.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "1.9007155E9")
- assertTrue(result[0][6] == "10.0")
- assertTrue(result[0][7] == "\'1749-09-24\'")
- assertTrue(result[0][8] == "\'2023-05-26\'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "event_day")
+ assertEquals(result[0][2], "1.9007155E8")
+ assertEquals(result[0][3], "99949.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "1.9007155E9")
+ assertEquals(result[0][6], "10.0")
+ assertEquals(result[0][7], "\'1749-09-24\'")
+ assertEquals(result[0][8], "\'2023-05-26\'")
sql """analyze table ${catalog_name}.partition_type.tinyint_partition
(tinyint_part) with sync"""
sql """analyze table ${catalog_name}.partition_type.smallint_partition
(smallint_part) with sync"""
@@ -76,153 +76,153 @@ suite("test_hive_partition_column_analyze",
"p2,external,hive,external_remote,ex
sql """use partition_type;"""
result = sql """show column stats tinyint_partition (tinyint_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "tinyint_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "141474.0")
- assertTrue(result[0][6] == "1.0")
- assertTrue(result[0][7] == "1")
- assertTrue(result[0][8] == "100")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "tinyint_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "141474.0")
+ assertEquals(result[0][6], "1.0")
+ assertEquals(result[0][7], "1")
+ assertEquals(result[0][8], "100")
result = sql """show column stats smallint_partition (smallint_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "smallint_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "282948.0")
- assertTrue(result[0][6] == "2.0")
- assertTrue(result[0][7] == "1")
- assertTrue(result[0][8] == "100")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "smallint_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "282948.0")
+ assertEquals(result[0][6], "2.0")
+ assertEquals(result[0][7], "1")
+ assertEquals(result[0][8], "100")
result = sql """show column stats int_partition (int_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "int_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "565896.0")
- assertTrue(result[0][6] == "4.0")
- assertTrue(result[0][7] == "1")
- assertTrue(result[0][8] == "100")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "int_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "565896.0")
+ assertEquals(result[0][6], "4.0")
+ assertEquals(result[0][7], "1")
+ assertEquals(result[0][8], "100")
result = sql """show column stats bigint_partition (bigint_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "bigint_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "1131792.0")
- assertTrue(result[0][6] == "8.0")
- assertTrue(result[0][7] == "1")
- assertTrue(result[0][8] == "100")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "bigint_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "1131792.0")
+ assertEquals(result[0][6], "8.0")
+ assertEquals(result[0][7], "1")
+ assertEquals(result[0][8], "100")
result = sql """show column stats char_partition (char_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "char_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "101.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "2829480.0")
- assertTrue(result[0][6] == "20.0")
- assertTrue(result[0][7] == "\'1 \'")
- assertTrue(result[0][8] == "\'a \'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "char_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "101.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "2829480.0")
+ assertEquals(result[0][6], "20.0")
+ assertEquals(result[0][7], "\'1 \'")
+ assertEquals(result[0][8], "\'a \'")
result = sql """show column stats varchar_partition (varchar_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "varchar_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "271630.0")
- assertTrue(result[0][6] == "1.9199994345250717")
- assertTrue(result[0][7] == "\'1\'")
- assertTrue(result[0][8] == "\'99\'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "varchar_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "271630.0")
+ assertEquals(result[0][6], "1.9199994345250717")
+ assertEquals(result[0][7], "\'1\'")
+ assertEquals(result[0][8], "\'99\'")
result = sql """show column stats string_partition (string_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "string_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "271630.0")
- assertTrue(result[0][6] == "1.9199994345250717")
- assertTrue(result[0][7] == "\'1\'")
- assertTrue(result[0][8] == "\'99\'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "string_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "271630.0")
+ assertEquals(result[0][6], "1.9199994345250717")
+ assertEquals(result[0][7], "\'1\'")
+ assertEquals(result[0][8], "\'99\'")
result = sql """show column stats date_partition (date_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "date_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "565896.0")
- assertTrue(result[0][6] == "4.0")
- assertTrue(result[0][7] == "\'2001-10-12\'")
- assertTrue(result[0][8] == "\'2100-10-12\'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "date_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "565896.0")
+ assertEquals(result[0][6], "4.0")
+ assertEquals(result[0][7], "\'2001-10-12\'")
+ assertEquals(result[0][8], "\'2100-10-12\'")
result = sql """show column stats float_partition (float_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "float_part")
- assertTrue(result[0][2] == "117416.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "469664.0")
- assertTrue(result[0][6] == "4.0")
- assertTrue(result[0][7] == "296.31")
- assertTrue(result[0][8] == "32585.627")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "float_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "565896.0")
+ assertEquals(result[0][6], "4.0")
+ assertEquals(result[0][7], "296.3103")
+ assertEquals(result[0][8], "32585.627")
result = sql """show column stats double_partition (double_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "double_part")
- assertTrue(result[0][2] == "16987.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "135896.0")
- assertTrue(result[0][6] == "8.0")
- assertTrue(result[0][7] == "115.145")
- assertTrue(result[0][8] == "32761.145")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "double_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "1131792.0")
+ assertEquals(result[0][6], "8.0")
+ assertEquals(result[0][7], "115.14474")
+ assertEquals(result[0][8], "32761.14458")
result = sql """show column stats decimal_partition (decimal_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "decimal_part")
- assertTrue(result[0][2] == "141474.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "1131792.0")
- assertTrue(result[0][6] == "8.0")
- assertTrue(result[0][7] == "243.2868")
- assertTrue(result[0][8] == "32527.1543")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "decimal_part")
+ assertEquals(result[0][2], "141474.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "1131792.0")
+ assertEquals(result[0][6], "8.0")
+ assertEquals(result[0][7], "243.2868")
+ assertEquals(result[0][8], "32527.1543")
sql """analyze table ${catalog_name}.partition_type.decimal_partition
(decimal_part) with sync with sql"""
result = sql """show column stats decimal_partition (decimal_part)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "decimal_part")
- assertTrue(result[0][2] == "100000.0")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][5] == "800000.0")
- assertTrue(result[0][6] == "8.0")
- assertTrue(result[0][7] == "243.2868")
- assertTrue(result[0][8] == "32527.1543")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "decimal_part")
+ assertEquals(result[0][2], "100000.0")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][5], "800000.0")
+ assertEquals(result[0][6], "8.0")
+ assertEquals(result[0][7], "243.2868")
+ assertEquals(result[0][8], "32527.1543")
result = sql """show column stats two_partition (part1)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "part1")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][7] == "1")
- assertTrue(result[0][8] == "100")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "part1")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][7], "1")
+ assertEquals(result[0][8], "100")
result = sql """show column stats two_partition (part2)"""
- assertTrue(result.size() == 1)
- assertTrue(result[0][0] == "part2")
- assertTrue(result[0][3] == "100.0")
- assertTrue(result[0][4] == "0.0")
- assertTrue(result[0][7] == "\'1\'")
- assertTrue(result[0][8] == "\'99\'")
+ assertEquals(result.size(), 1)
+ assertEquals(result[0][0], "part2")
+ assertEquals(result[0][3], "100.0")
+ assertEquals(result[0][4], "0.0")
+ assertEquals(result[0][7], "\'1\'")
+ assertEquals(result[0][8], "\'99\'")
sql """drop catalog ${catalog_name}"""
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
