From 4a8a662cd3c8dfa820c4fa526fd16edfbf004491 Mon Sep 17 00:00:00 2001 From: brfrn169 Date: Wed, 4 Jun 2025 15:13:03 +0900 Subject: [PATCH] Merge ConsensusCommitTestUtils and ConsensusCommitIntegrationTestUtils --- .../cassandra/ConsensusCommitCassandraEnv.java | 3 +-- .../storage/cosmos/ConsensusCommitCosmosEnv.java | 3 +-- .../storage/dynamo/ConsensusCommitDynamoEnv.java | 3 +-- .../db/storage/jdbc/ConsensusCommitJdbcEnv.java | 3 +-- .../MultiStorageSchemaLoaderIntegrationTest.java | 10 ++++------ ...CommitAdminImportTableIntegrationTestBase.java | 2 +- .../ConsensusCommitAdminIntegrationTestBase.java | 2 +- ...ensusCommitAdminRepairIntegrationTestBase.java | 2 +- ...mmitCrossPartitionScanIntegrationTestBase.java | 2 +- .../ConsensusCommitIntegrationTestBase.java | 2 +- .../ConsensusCommitIntegrationTestUtils.java | 15 --------------- ...nsusCommitNullMetadataIntegrationTestBase.java | 2 +- ...onsensusCommitSpecificIntegrationTestBase.java | 2 +- .../consensuscommit/ConsensusCommitTestUtils.java | 7 +++++++ ...IncludeMetadataEnabledIntegrationTestBase.java | 2 +- ...mmitCrossPartitionScanIntegrationTestBase.java | 4 ++-- ...woPhaseConsensusCommitIntegrationTestBase.java | 4 ++-- ...onsensusCommitSpecificIntegrationTestBase.java | 4 ++-- ...IncludeMetadataEnabledIntegrationTestBase.java | 2 +- 19 files changed, 30 insertions(+), 44 deletions(-) delete mode 100644 integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestUtils.java diff --git a/core/src/integration-test/java/com/scalar/db/storage/cassandra/ConsensusCommitCassandraEnv.java b/core/src/integration-test/java/com/scalar/db/storage/cassandra/ConsensusCommitCassandraEnv.java index 31e8d585e1..dd4a3e9999 100644 --- a/core/src/integration-test/java/com/scalar/db/storage/cassandra/ConsensusCommitCassandraEnv.java +++ b/core/src/integration-test/java/com/scalar/db/storage/cassandra/ConsensusCommitCassandraEnv.java @@ -1,6 +1,5 @@ package com.scalar.db.storage.cassandra; -import com.scalar.db.transaction.consensuscommit.ConsensusCommitIntegrationTestUtils; import com.scalar.db.transaction.consensuscommit.ConsensusCommitTestUtils; import java.util.Properties; @@ -11,7 +10,7 @@ public static Properties getProperties(String testName) { Properties properties = CassandraEnv.getProperties(testName); // Add testName as a coordinator schema suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return ConsensusCommitTestUtils.loadConsensusCommitProperties(properties); } diff --git a/core/src/integration-test/java/com/scalar/db/storage/cosmos/ConsensusCommitCosmosEnv.java b/core/src/integration-test/java/com/scalar/db/storage/cosmos/ConsensusCommitCosmosEnv.java index d9b61a2be8..4cf5939e8c 100644 --- a/core/src/integration-test/java/com/scalar/db/storage/cosmos/ConsensusCommitCosmosEnv.java +++ b/core/src/integration-test/java/com/scalar/db/storage/cosmos/ConsensusCommitCosmosEnv.java @@ -1,6 +1,5 @@ package com.scalar.db.storage.cosmos; -import com.scalar.db.transaction.consensuscommit.ConsensusCommitIntegrationTestUtils; import com.scalar.db.transaction.consensuscommit.ConsensusCommitTestUtils; import java.util.Map; import java.util.Properties; @@ -12,7 +11,7 @@ public static Properties getProperties(String testName) { Properties properties = CosmosEnv.getProperties(testName); // Add testName as a coordinator schema suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return ConsensusCommitTestUtils.loadConsensusCommitProperties(properties); } diff --git a/core/src/integration-test/java/com/scalar/db/storage/dynamo/ConsensusCommitDynamoEnv.java b/core/src/integration-test/java/com/scalar/db/storage/dynamo/ConsensusCommitDynamoEnv.java index dd636cae75..c751acf4ba 100644 --- a/core/src/integration-test/java/com/scalar/db/storage/dynamo/ConsensusCommitDynamoEnv.java +++ b/core/src/integration-test/java/com/scalar/db/storage/dynamo/ConsensusCommitDynamoEnv.java @@ -1,6 +1,5 @@ package com.scalar.db.storage.dynamo; -import com.scalar.db.transaction.consensuscommit.ConsensusCommitIntegrationTestUtils; import com.scalar.db.transaction.consensuscommit.ConsensusCommitTestUtils; import java.util.Map; import java.util.Properties; @@ -12,7 +11,7 @@ public static Properties getProperties(String testName) { Properties properties = DynamoEnv.getProperties(testName); // Add testName as a coordinator schema suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return ConsensusCommitTestUtils.loadConsensusCommitProperties(properties); } diff --git a/core/src/integration-test/java/com/scalar/db/storage/jdbc/ConsensusCommitJdbcEnv.java b/core/src/integration-test/java/com/scalar/db/storage/jdbc/ConsensusCommitJdbcEnv.java index a1650f8cc5..2adc3ee4e8 100644 --- a/core/src/integration-test/java/com/scalar/db/storage/jdbc/ConsensusCommitJdbcEnv.java +++ b/core/src/integration-test/java/com/scalar/db/storage/jdbc/ConsensusCommitJdbcEnv.java @@ -1,6 +1,5 @@ package com.scalar.db.storage.jdbc; -import com.scalar.db.transaction.consensuscommit.ConsensusCommitIntegrationTestUtils; import com.scalar.db.transaction.consensuscommit.ConsensusCommitTestUtils; import java.util.Properties; @@ -11,7 +10,7 @@ public static Properties getProperties(String testName) { Properties properties = JdbcEnv.getProperties(testName); // Add testName as a coordinator schema suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return ConsensusCommitTestUtils.loadConsensusCommitProperties(properties); } diff --git a/core/src/integration-test/java/com/scalar/db/storage/multistorage/MultiStorageSchemaLoaderIntegrationTest.java b/core/src/integration-test/java/com/scalar/db/storage/multistorage/MultiStorageSchemaLoaderIntegrationTest.java index 6d9ccc111e..8c12950bef 100644 --- a/core/src/integration-test/java/com/scalar/db/storage/multistorage/MultiStorageSchemaLoaderIntegrationTest.java +++ b/core/src/integration-test/java/com/scalar/db/storage/multistorage/MultiStorageSchemaLoaderIntegrationTest.java @@ -4,7 +4,7 @@ import com.google.common.util.concurrent.Uninterruptibles; import com.scalar.db.config.DatabaseConfig; import com.scalar.db.schemaloader.SchemaLoaderIntegrationTestBase; -import com.scalar.db.transaction.consensuscommit.ConsensusCommitIntegrationTestUtils; +import com.scalar.db.transaction.consensuscommit.ConsensusCommitTestUtils; import com.scalar.db.transaction.consensuscommit.Coordinator; import com.scalar.db.util.AdminTestUtils; import java.nio.file.Path; @@ -59,7 +59,7 @@ protected Properties getProperties(String testName) { DatabaseConfig.DEFAULT_SYSTEM_NAMESPACE_NAME + "_" + testName); // Add testName as a coordinator schema suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } @@ -67,12 +67,10 @@ protected Properties getProperties(String testName) { @Override protected AdminTestUtils getAdminTestUtils(String testName) { Properties propertiesForCassandra = MultiStorageEnv.getPropertiesForCassandra(testName); - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace( - propertiesForCassandra, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(propertiesForCassandra, testName); Properties propertiesForJdbc = MultiStorageEnv.getPropertiesForJdbc(testName); - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace( - propertiesForJdbc, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(propertiesForJdbc, testName); return new MultiStorageAdminTestUtils(propertiesForCassandra, propertiesForJdbc); } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminImportTableIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminImportTableIntegrationTestBase.java index 3839e09580..dcf75be9d8 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminImportTableIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminImportTableIntegrationTestBase.java @@ -12,7 +12,7 @@ protected final Properties getProperties(String testName) { properties.putAll(getProps(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminIntegrationTestBase.java index e35015b424..4b535150dc 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminIntegrationTestBase.java @@ -17,7 +17,7 @@ protected final Properties getProperties(String testName) { properties.putAll(getProps(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminRepairIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminRepairIntegrationTestBase.java index 95b4752fe3..1d520a653a 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminRepairIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitAdminRepairIntegrationTestBase.java @@ -12,7 +12,7 @@ protected final Properties getProperties(String testName) { properties.putAll(getProps(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitCrossPartitionScanIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitCrossPartitionScanIntegrationTestBase.java index 2b33432eff..99682fe904 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitCrossPartitionScanIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitCrossPartitionScanIntegrationTestBase.java @@ -28,7 +28,7 @@ protected final Properties getProperties(String testName) { properties.putAll(getProps(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestBase.java index bf5abaae05..da572b4de8 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestBase.java @@ -31,7 +31,7 @@ protected final Properties getProperties(String testName) { properties.putAll(getProps(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestUtils.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestUtils.java deleted file mode 100644 index c3a08908c7..0000000000 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitIntegrationTestUtils.java +++ /dev/null @@ -1,15 +0,0 @@ -package com.scalar.db.transaction.consensuscommit; - -import java.util.Properties; - -public final class ConsensusCommitIntegrationTestUtils { - - private ConsensusCommitIntegrationTestUtils() {} - - public static void addSuffixToCoordinatorNamespace(Properties properties, String suffix) { - String coordinatorNamespace = - properties.getProperty(ConsensusCommitConfig.COORDINATOR_NAMESPACE, Coordinator.NAMESPACE); - properties.setProperty( - ConsensusCommitConfig.COORDINATOR_NAMESPACE, coordinatorNamespace + "_" + suffix); - } -} diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitNullMetadataIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitNullMetadataIntegrationTestBase.java index 78e8aad1b4..1a84d83d41 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitNullMetadataIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitNullMetadataIntegrationTestBase.java @@ -83,7 +83,7 @@ public void beforeAll() throws Exception { Properties properties = getProperties(TEST_NAME); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); StorageFactory factory = StorageFactory.create(properties); admin = factory.getStorageAdmin(); diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitSpecificIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitSpecificIntegrationTestBase.java index e4a31e9673..645b1fc991 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitSpecificIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitSpecificIntegrationTestBase.java @@ -111,7 +111,7 @@ public void beforeAll() throws Exception { Properties properties = getProperties(TEST_NAME); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); StorageFactory factory = StorageFactory.create(properties); admin = factory.getStorageAdmin(); diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitTestUtils.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitTestUtils.java index f7ec3b18b8..0d9aeb9797 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitTestUtils.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitTestUtils.java @@ -71,4 +71,11 @@ public static Properties loadConsensusCommitProperties(Properties properties) { COORDINATOR_GROUP_COMMIT_METRICS_MONITOR_LOG_ENABLED); return properties; } + + public static void addSuffixToCoordinatorNamespace(Properties properties, String suffix) { + String coordinatorNamespace = + properties.getProperty(ConsensusCommitConfig.COORDINATOR_NAMESPACE, Coordinator.NAMESPACE); + properties.setProperty( + ConsensusCommitConfig.COORDINATOR_NAMESPACE, coordinatorNamespace + "_" + suffix); + } } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java index 0f1dba0f66..4cdeb6878f 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/ConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java @@ -60,7 +60,7 @@ public void beforeAll() throws Exception { Properties properties = getProperties(TEST_NAME); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); // Enable to include metadata properties.setProperty(ConsensusCommitConfig.INCLUDE_METADATA_ENABLED, "true"); diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitCrossPartitionScanIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitCrossPartitionScanIntegrationTestBase.java index 17fc2202d0..068ad436e8 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitCrossPartitionScanIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitCrossPartitionScanIntegrationTestBase.java @@ -28,7 +28,7 @@ protected final Properties getProperties1(String testName) { properties.putAll(getProps1(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } @@ -39,7 +39,7 @@ protected final Properties getProperties2(String testName) { properties.putAll(getProps2(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitIntegrationTestBase.java index 781087ed79..43ed6a3d8d 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitIntegrationTestBase.java @@ -17,7 +17,7 @@ protected final Properties getProperties1(String testName) { properties.putAll(getProps1(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } @@ -28,7 +28,7 @@ protected final Properties getProperties2(String testName) { properties.putAll(getProps2(testName)); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, testName); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, testName); return properties; } diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitSpecificIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitSpecificIntegrationTestBase.java index 28ad7d657b..cbad6a4459 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitSpecificIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitSpecificIntegrationTestBase.java @@ -74,11 +74,11 @@ public void beforeAll() throws Exception { initialize(); Properties properties1 = getProperties1(TEST_NAME); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties1, TEST_NAME); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties1, TEST_NAME); Properties properties2 = getProperties2(TEST_NAME); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties2, TEST_NAME); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties2, TEST_NAME); namespace1 = getNamespace1(); namespace2 = getNamespace2(); diff --git a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java index 71d5526f58..446f72a2e1 100644 --- a/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java +++ b/integration-test/src/main/java/com/scalar/db/transaction/consensuscommit/TwoPhaseConsensusCommitWithIncludeMetadataEnabledIntegrationTestBase.java @@ -60,7 +60,7 @@ public void beforeAll() throws Exception { Properties properties = getProperties(TEST_NAME); // Add testName as a coordinator namespace suffix - ConsensusCommitIntegrationTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); + ConsensusCommitTestUtils.addSuffixToCoordinatorNamespace(properties, TEST_NAME); // Enable to include metadata properties.setProperty(ConsensusCommitConfig.INCLUDE_METADATA_ENABLED, "true");