From 809463371fba3812263cb2a4e3c4c8b988c8abc5 Mon Sep 17 00:00:00 2001 From: Yuya Ebihara Date: Fri, 19 Apr 2024 09:57:26 +0900 Subject: [PATCH] Move testConcurrentInsertsReconciliationForBlindInserts in Delta Lake --- .../BaseDeltaLakeConnectorSmokeTest.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java index 78dfd2503fdd..d5157e3cd178 100644 --- a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java +++ b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeConnectorSmokeTest.java @@ -2290,14 +2290,6 @@ public void testPartitionFilterIncluded() } } - @RepeatedTest(3) - public void testConcurrentInsertsReconciliationForBlindInserts() - throws Exception - { - testConcurrentInsertsReconciliationForBlindInserts(false); - testConcurrentInsertsReconciliationForBlindInserts(true); - } - @Test public void testCreateOrReplaceTable() { @@ -2432,6 +2424,14 @@ private void assertTableOperation(String tableName, long version, String operati "VALUES '%s'".formatted(operation)); } + @RepeatedTest(3) + public void testConcurrentInsertsReconciliationForBlindInserts() + throws Exception + { + testConcurrentInsertsReconciliationForBlindInserts(false); + testConcurrentInsertsReconciliationForBlindInserts(true); + } + private void testConcurrentInsertsReconciliationForBlindInserts(boolean partitioned) throws Exception {