diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/BaseTestSyncPartitionMetadata.java b/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/BaseTestSyncPartitionMetadata.java index 7cfb26cf9630..9cb308166d0d 100644 --- a/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/BaseTestSyncPartitionMetadata.java +++ b/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/BaseTestSyncPartitionMetadata.java @@ -13,8 +13,6 @@ */ package io.trino.tests.product.hive; -import io.trino.tempto.AfterTestWithContext; -import io.trino.tempto.BeforeTestWithContext; import io.trino.tempto.ProductTest; import io.trino.tempto.assertions.QueryAssert; import io.trino.tempto.query.QueryResult; @@ -34,19 +32,6 @@ public abstract class BaseTestSyncPartitionMetadata extends ProductTest { - @BeforeTestWithContext - public void setUp() - { - removeHdfsDirectory(schemaLocation()); - makeHdfsDirectory(schemaLocation()); - } - - @AfterTestWithContext - public void tearDown() - { - removeHdfsDirectory(schemaLocation()); - } - public void testAddPartition() { String tableName = "test_sync_partition_metadata_add_partition"; diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestAbfsSyncPartitionMetadata.java b/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestAbfsSyncPartitionMetadata.java index 328deef64c34..036a3602a52d 100644 --- a/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestAbfsSyncPartitionMetadata.java +++ b/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestAbfsSyncPartitionMetadata.java @@ -13,6 +13,8 @@ */ package io.trino.tests.product.hive; +import io.trino.tempto.AfterTestWithContext; +import io.trino.tempto.BeforeTestWithContext; import io.trino.testng.services.Flaky; import org.testng.annotations.Test; @@ -33,6 +35,19 @@ public class TestAbfsSyncPartitionMetadata { private final String schema = "test_" + randomTableSuffix(); + @BeforeTestWithContext + public void setUp() + { + removeHdfsDirectory(schemaLocation()); + makeHdfsDirectory(schemaLocation()); + } + + @AfterTestWithContext + public void tearDown() + { + removeHdfsDirectory(schemaLocation()); + } + @Override protected String schemaLocation() { diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestHdfsSyncPartitionMetadata.java b/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestHdfsSyncPartitionMetadata.java index 4b2e952c1216..321c0c7bf2c7 100644 --- a/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestHdfsSyncPartitionMetadata.java +++ b/testing/trino-product-tests/src/main/java/io/trino/tests/product/hive/TestHdfsSyncPartitionMetadata.java @@ -27,8 +27,6 @@ import static io.trino.tests.product.TestGroups.TRINO_JDBC; import static io.trino.tests.product.hive.HiveProductTest.ERROR_COMMITTING_WRITE_TO_HIVE_ISSUE; import static io.trino.tests.product.hive.HiveProductTest.ERROR_COMMITTING_WRITE_TO_HIVE_MATCH; -import static io.trino.tests.product.hive.util.TemporaryHiveTable.randomTableSuffix; -import static java.lang.String.format; public class TestHdfsSyncPartitionMetadata extends BaseTestSyncPartitionMetadata @@ -41,12 +39,10 @@ public class TestHdfsSyncPartitionMetadata @Inject private HdfsDataSourceWriter hdfsDataSourceWriter; - private final String schema = "test_" + randomTableSuffix(); - @Override protected String schemaLocation() { - return format("%s/%s", warehouseDirectory, schema); + return warehouseDirectory; } @Test(groups = {HIVE_PARTITIONING, SMOKE, TRINO_JDBC})