diff --git a/plugin/trino-bigquery/src/test/java/io/trino/plugin/bigquery/BaseBigQueryFailureRecoveryTest.java b/plugin/trino-bigquery/src/test/java/io/trino/plugin/bigquery/BaseBigQueryFailureRecoveryTest.java index 6fc21af7f025..e03130d0c6b4 100644 --- a/plugin/trino-bigquery/src/test/java/io/trino/plugin/bigquery/BaseBigQueryFailureRecoveryTest.java +++ b/plugin/trino-bigquery/src/test/java/io/trino/plugin/bigquery/BaseBigQueryFailureRecoveryTest.java @@ -19,6 +19,7 @@ import io.trino.testing.BaseFailureRecoveryTest; import io.trino.testing.QueryRunner; import io.trino.tpch.TpchTable; +import org.junit.jupiter.api.Test; import java.util.List; import java.util.Map; @@ -53,12 +54,14 @@ protected QueryRunner createQueryRunner( }); } + @Test @Override protected boolean areWriteRetriesSupported() { return true; } + @Test @Override protected void testAnalyzeTable() { @@ -66,6 +69,7 @@ protected void testAnalyzeTable() abort("skipped"); } + @Test @Override protected void testDelete() { @@ -73,6 +77,7 @@ protected void testDelete() abort("skipped"); } + @Test @Override protected void testDeleteWithSubquery() { @@ -80,6 +85,7 @@ protected void testDeleteWithSubquery() abort("skipped"); } + @Test @Override protected void testMerge() { @@ -87,6 +93,7 @@ protected void testMerge() abort("skipped"); } + @Test @Override protected void testRefreshMaterializedView() { @@ -94,6 +101,7 @@ protected void testRefreshMaterializedView() abort("skipped"); } + @Test @Override protected void testUpdate() { @@ -101,6 +109,7 @@ protected void testUpdate() abort("skipped"); } + @Test @Override protected void testUpdateWithSubquery() { diff --git a/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/BaseRedshiftFailureRecoveryTest.java b/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/BaseRedshiftFailureRecoveryTest.java index e04f8eda1215..8ef65af2f579 100644 --- a/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/BaseRedshiftFailureRecoveryTest.java +++ b/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/BaseRedshiftFailureRecoveryTest.java @@ -19,6 +19,7 @@ import io.trino.plugin.jdbc.BaseJdbcFailureRecoveryTest; import io.trino.testing.QueryRunner; import io.trino.tpch.TpchTable; +import org.junit.jupiter.api.Test; import java.util.List; import java.util.Map; @@ -55,6 +56,7 @@ protected QueryRunner createQueryRunner( }); } + @Test @Override protected void testUpdateWithSubquery() { @@ -62,6 +64,7 @@ protected void testUpdateWithSubquery() abort("skipped"); } + @Test @Override protected void testUpdate() {