This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 558c8924fb1 branch-4.1: [fix](regression) Stabilize initial rowset
visibility check #66267 (#66454)
558c8924fb1 is described below
commit 558c8924fb10867bc97e293078202d107d908699
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Aug 5 19:39:02 2026 +0800
branch-4.1: [fix](regression) Stabilize initial rowset visibility check
#66267 (#66454)
Cherry-picked from #66267
Co-authored-by: Jerry Hu <[email protected]>
---
.../query_p0/system/test_query_sys_rowsets.groovy | 19 +++++++++++++++++--
1 file changed, 17 insertions(+), 2 deletions(-)
diff --git
a/regression-test/suites/query_p0/system/test_query_sys_rowsets.groovy
b/regression-test/suites/query_p0/system/test_query_sys_rowsets.groovy
index 63f0646bd00..5025ec3bc35 100644
--- a/regression-test/suites/query_p0/system/test_query_sys_rowsets.groovy
+++ b/regression-test/suites/query_p0/system/test_query_sys_rowsets.groovy
@@ -45,8 +45,23 @@ suite("test_query_sys_rowsets", "query,p0") {
);
"""
- List<List<Object>> rowsets_table_name_tablets = sql """ show tablets
from ${rowsets_table_name} """
- order_qt_rowsets1 """ select START_VERSION,END_VERSION from
information_schema.rowsets where TABLET_ID=${rowsets_table_name_tablets[0][0]}
group by START_VERSION,END_VERSION order by START_VERSION,END_VERSION; """
+ List<List<Object>> rowsets_table_name_tablets = sql """ show tablets from
${rowsets_table_name} """
+ def tabletId = rowsets_table_name_tablets[0][0]
+ logger.info("Tablet metadata after creation:
${rowsets_table_name_tablets}")
+ // information_schema.rowsets is a distributed BE snapshot. Retry the
observation
+ // of the synchronously created initial rowset before validating the full
result.
+ awaitUntil(30) {
+ def visibleRowsets = sql """
+ select BACKEND_ID, ROWSET_ID, START_VERSION, END_VERSION,
+ CREATION_TIME, NEWEST_WRITE_TIMESTAMP
+ from information_schema.rowsets
+ where TABLET_ID = ${tabletId}
+ """
+ logger.info("Visible rowsets for tablet ${tabletId}:
${visibleRowsets}")
+ return visibleRowsets != null
+ && visibleRowsets.any { rowset -> rowset[2] == 0 && rowset[3]
== 1 }
+ }
+ order_qt_rowsets1 """ select START_VERSION,END_VERSION from
information_schema.rowsets where TABLET_ID=${tabletId} group by
START_VERSION,END_VERSION order by START_VERSION,END_VERSION; """
sql """ insert into ${rowsets_table_name} values (1,0,"abc"); """
order_qt_rowsets2 """ select START_VERSION,END_VERSION from
information_schema.rowsets where TABLET_ID=${rowsets_table_name_tablets[0][0]}
group by START_VERSION,END_VERSION order by START_VERSION,END_VERSION; """
sql """ insert into ${rowsets_table_name} values (2,1,"hello world");
"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
