You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by vh...@apache.org on 2025/08/27 11:48:45 UTC
(hudi) 07/13: [ENG-30914] Fix flakiness when testing cache correctness (#60)
This is an automated email from the ASF dual-hosted git repository.
vhs pushed a commit to branch HUDI-9767__upstream-trino-changes
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 4f4bfc0fd883175c42dd81d276e8d83dd1b181a1
Author: voonhous <vo...@gmail.com>
AuthorDate: Wed Aug 6 03:00:20 2025 +0800
[ENG-30914] Fix flakiness when testing cache correctness (#60)
(cherry picked from commit 2f3887d9368aba06b08bad0ebbac1229f14b2839)
---
.../java/io/trino/plugin/hudi/TestHudiAlluxioCacheFileOperations.java | 2 ++
.../test/java/io/trino/plugin/hudi/TestHudiAlluxioCachingSmokeTest.java | 2 ++
.../java/io/trino/plugin/hudi/TestHudiMemoryCacheFileOperations.java | 2 ++
3 files changed, 6 insertions(+)
diff --git a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCacheFileOperations.java b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCacheFileOperations.java
index 7101cb897d77..82e03799d1ed 100644
--- a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCacheFileOperations.java
+++ b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCacheFileOperations.java
@@ -26,6 +26,7 @@ import org.intellij.lang.annotations.Language;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.parallel.Execution;
import org.junit.jupiter.api.parallel.ExecutionMode;
+import org.junit.jupiter.api.parallel.ResourceLock;
import java.nio.file.Files;
import java.nio.file.Path;
@@ -43,6 +44,7 @@ import static io.trino.plugin.hudi.util.FileOperationUtils.FileType.TABLE_PROPER
import static io.trino.testing.MultisetAssertions.assertMultisetsEqual;
import static java.util.stream.Collectors.toCollection;
+@ResourceLock("HUDI_CACHE_SYSTEM")
@Execution(ExecutionMode.SAME_THREAD)
public class TestHudiAlluxioCacheFileOperations
extends AbstractTestQueryFramework
diff --git a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCachingSmokeTest.java b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCachingSmokeTest.java
index 0a082e1cb159..9c191a20e34c 100644
--- a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCachingSmokeTest.java
+++ b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiAlluxioCachingSmokeTest.java
@@ -16,6 +16,7 @@ package io.trino.plugin.hudi;
import com.google.common.collect.ImmutableMap;
import com.google.common.io.Closer;
import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.parallel.ResourceLock;
import java.io.IOException;
import java.nio.file.Files;
@@ -24,6 +25,7 @@ import java.nio.file.Path;
import static com.google.common.io.MoreFiles.deleteRecursively;
import static com.google.common.io.RecursiveDeleteOption.ALLOW_INSECURE;
+@ResourceLock("HUDI_CACHE_SYSTEM")
public class TestHudiAlluxioCachingSmokeTest
extends TestHudiSmokeTest
{
diff --git a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiMemoryCacheFileOperations.java b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiMemoryCacheFileOperations.java
index 707a53b22ed4..5799ce17893c 100644
--- a/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiMemoryCacheFileOperations.java
+++ b/hudi-trino-plugin/src/test/java/io/trino/plugin/hudi/TestHudiMemoryCacheFileOperations.java
@@ -26,6 +26,7 @@ import org.intellij.lang.annotations.Language;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.parallel.Execution;
import org.junit.jupiter.api.parallel.ExecutionMode;
+import org.junit.jupiter.api.parallel.ResourceLock;
import java.util.Map;
@@ -40,6 +41,7 @@ import static io.trino.plugin.hudi.util.FileOperationUtils.FileType.TABLE_PROPER
import static io.trino.testing.MultisetAssertions.assertMultisetsEqual;
import static java.util.stream.Collectors.toCollection;
+@ResourceLock("HUDI_CACHE_SYSTEM")
@Execution(ExecutionMode.SAME_THREAD)
public class TestHudiMemoryCacheFileOperations
extends AbstractTestQueryFramework