(hudi) branch master updated: test(trino): de-flake testRecordLevelFileSkipping by setting the record-index wait timeout (#19213)

[vhs]

This is an automated email from the ASF dual-hosted git repository.

voonhous pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new aefabf79f707 test(trino): de-flake testRecordLevelFileSkipping by 
setting the record-index wait timeout (#19213)
aefabf79f707 is described below

commit aefabf79f707fe5930f4dfc02b7952c19296af00
Author: Vova Kolmakov <wombatu...@gmail.com>
AuthorDate: Tue Jul 7 15:40:05 2026 +0700

    test(trino): de-flake testRecordLevelFileSkipping by setting the 
record-index wait timeout (#19213)
    
    testRecordLevelFileSkipping enables the record-level index but sets
    withColumnStatsTimeout("10s") - a no-op here, since column stats is 
disabled in this
    test - and never sets the record-index wait timeout, so the async RLI load 
falls back to
    the 2s default (HudiConfig#recordIndexWaitTimeout). Under CI load the RLI 
is not ready in
    2s, so file skipping is incomplete and the query scans 2 splits instead of 1
    (expected: 1 but was: 2).
    
    Replace the no-op withColumnStatsTimeout("10s") with 
withRecordIndexTimeout("10s"),
    matching the sibling RLI tests testRLIWithColumnNameUsingUppercaseLetters 
and
    testMultiKeyRLIWithColumnNameUsingUppercaseLetters and the earlier de-flake 
#13869.
    Test-only.
    
    Co-authored-by: Vova Kolmakov <wombatu...@apache.org>
---
 .../src/test/java/io/trino/plugin/hudi/TestHudiSmokeTest.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiSmokeTest.java 
b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiSmokeTest.java
index f49933d3fb98..0e19f2a05177 100644
--- 
a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiSmokeTest.java
+++ 
b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiSmokeTest.java
@@ -801,7 +801,7 @@ public class TestHudiSmokeTest
                 .withRecordLevelIndexEnabled(true)
                 .withSecondaryIndexEnabled(false)
                 .withPartitionStatsIndexEnabled(false)
-                .withColumnStatsTimeout("10s")
+                .withRecordIndexTimeout("10s")
                 .build();
         MaterializedResult totalRes = getQueryRunner().execute(session, 
"SELECT * FROM " + table);
         MaterializedResult prunedRes = getQueryRunner().execute(session, 
"SELECT * FROM " + table