This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 940bbee2fa8 branch-3.0: [fix](regression case) Fix
`test_dynamic_partition_with_update` regre… (#43232)
940bbee2fa8 is described below
commit 940bbee2fa8d762c39470b297d7bd702b17d4b2a
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Nov 7 11:30:19 2024 +0800
branch-3.0: [fix](regression case) Fix `test_dynamic_partition_with_update`
regre… (#43232)
Cherry-picked from #43077
Co-authored-by: deardeng <[email protected]>
---
.../test_dynamic_partition.groovy | 25 ++++++++++++++++------
1 file changed, 18 insertions(+), 7 deletions(-)
diff --git
a/regression-test/suites/partition_p1/dynamic_partition/test_dynamic_partition.groovy
b/regression-test/suites/partition_p1/dynamic_partition/test_dynamic_partition.groovy
index a9dfcce8eac..d9307dc0f33 100644
---
a/regression-test/suites/partition_p1/dynamic_partition/test_dynamic_partition.groovy
+++
b/regression-test/suites/partition_p1/dynamic_partition/test_dynamic_partition.groovy
@@ -15,6 +15,9 @@
// specific language governing permissions and limitations
// under the License.
+import java.util.concurrent.TimeUnit
+import org.awaitility.Awaitility
+
suite("test_dynamic_partition_with_update", "nonConcurrent") {
sql "drop table if exists test_dynamic_partition_with_update"
sql """
@@ -40,13 +43,13 @@ suite("test_dynamic_partition_with_update",
"nonConcurrent") {
// check table init
def result = sql "show partitions from test_dynamic_partition_with_update"
assertEquals(7, result.size())
- result = sql "show dynamic partition tables"
- assertEquals("true",result.get(0).get(1))
+ result = sql_return_maparray "show dynamic partition tables"
+ assertEquals("true",result.get(0).Enable)
// disable dynamic partition to insert partition
sql """ alter table test_dynamic_partition_with_update set
('dynamic_partition.enable' = 'false') """
- result = sql "show dynamic partition tables"
- assertEquals("false",result.get(0).get(1))
+ result = sql_return_maparray "show dynamic partition tables"
+ assertEquals("false",result.get(0).Enable)
// manually insert partition
sql """ alter table test_dynamic_partition_with_update add partition p1
values [("2020-01-02"), ("2020-01-05")) """
@@ -58,11 +61,19 @@ suite("test_dynamic_partition_with_update",
"nonConcurrent") {
result = sql "show partitions from test_dynamic_partition_with_update"
assertEquals(11, result.size())
sql """ alter table test_dynamic_partition_with_update set
('dynamic_partition.enable' = 'true') """
- result = sql "show dynamic partition tables"
- assertEquals("true",result.get(0).get(1))
+ result = sql_return_maparray "show dynamic partition tables"
+ assertEquals("true",result.get(0).Enable)
// check and update
- sleep(3000)
+ // ATTN: due to dynamic_partition_check_interval_seconds default 600s, if
DynamicPartitionScheduler in sleep
+ // set config dynamic_partition_check_interval_seconds = 1 not work, so at
most wait > 600
+ Awaitility.await().atMost(1200, TimeUnit.SECONDS).pollInterval(1,
TimeUnit.SECONDS).until(
+ {
+ result = sql "show partitions from
test_dynamic_partition_with_update"
+ logger.info("result: ${result}")
+ result.size() == 8
+ }
+ )
// check size
result = sql "show partitions from test_dynamic_partition_with_update"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
