diff --git a/plugin/trino-oracle/src/test/java/io/trino/plugin/oracle/BaseOracleFailureRecoveryTest.java b/plugin/trino-oracle/src/test/java/io/trino/plugin/oracle/BaseOracleFailureRecoveryTest.java index b1ac7e91ed38..be0c7ae0ff13 100644 --- a/plugin/trino-oracle/src/test/java/io/trino/plugin/oracle/BaseOracleFailureRecoveryTest.java +++ b/plugin/trino-oracle/src/test/java/io/trino/plugin/oracle/BaseOracleFailureRecoveryTest.java @@ -18,7 +18,9 @@ import io.trino.plugin.exchange.filesystem.FileSystemExchangePlugin; import io.trino.plugin.jdbc.BaseJdbcFailureRecoveryTest; import io.trino.testing.QueryRunner; +import io.trino.testng.services.Flaky; import io.trino.tpch.TpchTable; +import org.testng.annotations.Test; import java.util.List; import java.util.Map; @@ -59,4 +61,12 @@ protected QueryRunner createQueryRunner( "exchange.base-directories", System.getProperty("java.io.tmpdir") + "/trino-local-file-system-exchange-manager")); }); } + + @Override + @Flaky(issue = "https://github.com/trinodb/trino/issues/16277", match = "There should be no remaining tmp_trino tables that are queryable") + @Test(dataProvider = "parallelTests") + public void testParallel(Runnable runnable) + { + super.testParallel(runnable); + } } diff --git a/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java b/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java index 59732e5e5c47..9a6e8d1e8938 100644 --- a/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java +++ b/testing/trino-testing/src/main/java/io/trino/testing/BaseFailureRecoveryTest.java @@ -209,7 +209,7 @@ public Object[][] parallelTests() } @Test(dataProvider = "parallelTests") - public final void testParallel(Runnable runnable) + public void testParallel(Runnable runnable) { try { // By default, a test method using a @DataProvider with parallel attribute is run in 10 threads (org.testng.xml.XmlSuite#DEFAULT_DATA_PROVIDER_THREAD_COUNT).