|
49 | 49 | import org.apache.iceberg.io.PositionOutputStream; |
50 | 50 | import org.apache.iceberg.rest.RESTCatalog; |
51 | 51 | import org.apache.iceberg.rest.auth.OAuth2Properties; |
52 | | -import org.apache.iceberg.rest.credentials.Credential; |
53 | 52 | import org.apache.iceberg.rest.responses.LoadTableResponse; |
54 | 53 | import org.apache.iceberg.types.Types; |
55 | 54 | import org.apache.polaris.core.admin.model.AwsStorageConfigInfo; |
@@ -268,16 +267,12 @@ public LoadTableResponse doTestCreateTable(RESTCatalog restCatalog) throws IOExc |
268 | 267 |
|
269 | 268 | LoadTableResponse loadTableResponse = |
270 | 269 | catalogApi.loadTableWithAccessDelegation(catalogName, id, "ALL"); |
271 | | - assertThat(loadTableResponse.config()).containsKey("s3.endpoint"); |
272 | | - assertThat(loadTableResponse.credentials().stream().map(Credential::config)) |
273 | | - .allSatisfy( |
274 | | - c -> |
275 | | - assertThat(c) |
276 | | - .containsEntry( |
277 | | - AwsClientProperties.REFRESH_CREDENTIALS_ENABLED, Boolean.TRUE.toString()) |
278 | | - .containsEntry( |
279 | | - AwsClientProperties.REFRESH_CREDENTIALS_ENDPOINT, |
280 | | - "v1/" + catalogName + "/namespaces/test-ns/tables/t1/credentials")); |
| 270 | + assertThat(loadTableResponse.config()) |
| 271 | + .containsKey("s3.endpoint") |
| 272 | + .containsEntry(AwsClientProperties.REFRESH_CREDENTIALS_ENABLED, Boolean.TRUE.toString()) |
| 273 | + .containsEntry( |
| 274 | + AwsClientProperties.REFRESH_CREDENTIALS_ENDPOINT, |
| 275 | + "v1/" + catalogName + "/namespaces/test-ns/tables/t1/credentials"); |
281 | 276 |
|
282 | 277 | restCatalog.dropTable(id); |
283 | 278 | assertThat(restCatalog.tableExists(id)).isFalse(); |
|
0 commit comments