|
47 | 47 | import static com.google.common.io.RecursiveDeleteOption.ALLOW_INSECURE; |
48 | 48 | import static java.lang.String.format; |
49 | 49 | import static org.apache.iceberg.rest.auth.OAuth2Properties.OAUTH2_SERVER_URI; |
50 | | -import static org.assertj.core.api.Assertions.assertThatThrownBy; |
51 | 50 | import static org.testng.Assert.assertEquals; |
52 | 51 |
|
53 | 52 | @Test |
@@ -128,69 +127,6 @@ protected Table getIcebergTable(ConnectorSession session, String schema, String |
128 | 127 | SchemaTableName.valueOf(schema + "." + tableName)); |
129 | 128 | } |
130 | 129 |
|
131 | | - @Test |
132 | | - public void testDeleteOnPartitionedV1Table() |
133 | | - { |
134 | | - // v1 table create fails due to Iceberg REST catalog bug (see: https://github.com/apache/iceberg/issues/8756) |
135 | | - assertThatThrownBy(super::testDeleteOnPartitionedV1Table) |
136 | | - .isInstanceOf(RuntimeException.class) |
137 | | - .hasMessageMatching("Cannot downgrade v2 table to v1"); |
138 | | - } |
139 | | - |
140 | | - @Test |
141 | | - public void testCreateTableWithFormatVersion() |
142 | | - { |
143 | | - // v1 table create fails due to Iceberg REST catalog bug (see: https://github.com/apache/iceberg/issues/8756) |
144 | | - assertThatThrownBy(() -> super.testMetadataDeleteOnNonIdentityPartitionColumn("1", "copy-on-write")) |
145 | | - .isInstanceOf(RuntimeException.class) |
146 | | - .hasMessageMatching("Cannot downgrade v2 table to v1"); |
147 | | - |
148 | | - // v2 succeeds |
149 | | - super.testCreateTableWithFormatVersion("2", "merge-on-read"); |
150 | | - } |
151 | | - |
152 | | - @Test(dataProvider = "version_and_mode") |
153 | | - public void testMetadataDeleteOnNonIdentityPartitionColumn(String version, String mode) |
154 | | - { |
155 | | - if (version.equals("1")) { |
156 | | - // v1 table create fails due to Iceberg REST catalog bug (see: https://github.com/apache/iceberg/issues/8756) |
157 | | - assertThatThrownBy(() -> super.testMetadataDeleteOnNonIdentityPartitionColumn(version, mode)) |
158 | | - .isInstanceOf(RuntimeException.class); |
159 | | - } |
160 | | - else { |
161 | | - // v2 succeeds |
162 | | - super.testMetadataDeleteOnNonIdentityPartitionColumn(version, mode); |
163 | | - } |
164 | | - } |
165 | | - |
166 | | - @Test(dataProvider = "version_and_mode") |
167 | | - public void testMetadataDeleteOnTableWithUnsupportedSpecsIncludingNoData(String version, String mode) |
168 | | - { |
169 | | - if (version.equals("1")) { |
170 | | - // v1 table create fails due to Iceberg REST catalog bug (see: https://github.com/apache/iceberg/issues/8756) |
171 | | - assertThatThrownBy(() -> super.testMetadataDeleteOnTableWithUnsupportedSpecsIncludingNoData(version, mode)) |
172 | | - .isInstanceOf(RuntimeException.class); |
173 | | - } |
174 | | - else { |
175 | | - // v2 succeeds |
176 | | - super.testMetadataDeleteOnTableWithUnsupportedSpecsIncludingNoData(version, mode); |
177 | | - } |
178 | | - } |
179 | | - |
180 | | - @Test(dataProvider = "version_and_mode") |
181 | | - public void testMetadataDeleteOnTableWithUnsupportedSpecsWhoseDataAllDeleted(String version, String mode) |
182 | | - { |
183 | | - if (version.equals("1")) { |
184 | | - // v1 table create fails due to Iceberg REST catalog bug (see: https://github.com/apache/iceberg/issues/8756) |
185 | | - assertThatThrownBy(() -> super.testMetadataDeleteOnTableWithUnsupportedSpecsWhoseDataAllDeleted(version, mode)) |
186 | | - .isInstanceOf(RuntimeException.class); |
187 | | - } |
188 | | - else { |
189 | | - // v2 succeeds |
190 | | - super.testMetadataDeleteOnTableWithUnsupportedSpecsWhoseDataAllDeleted(version, mode); |
191 | | - } |
192 | | - } |
193 | | - |
194 | 130 | @Test |
195 | 131 | public void testSetOauth2ServerUriPropertyI() |
196 | 132 | { |
|
0 commit comments