This is an automated email from the ASF dual-hosted git repository. voonhous pushed a commit to branch release-1.2.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit dc7eff474f167f46b76924c93df1f7c2344fff45 Author: Vova Kolmakov <[email protected]> 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 <[email protected]> (cherry picked from commit aefabf79f707fe5930f4dfc02b7952c19296af00) --- .../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
