diff --git a/integration-tests/src/main/java/org/apache/polaris/service/it/env/PolarisClient.java b/integration-tests/src/main/java/org/apache/polaris/service/it/env/PolarisClient.java index e0c2f38e8..b4fce998e 100644 --- a/integration-tests/src/main/java/org/apache/polaris/service/it/env/PolarisClient.java +++ b/integration-tests/src/main/java/org/apache/polaris/service/it/env/PolarisClient.java @@ -115,7 +115,7 @@ public String obtainToken(PrincipalWithCredentials principal) { /** Requests an access token from the Polaris server for the given {@link ClientCredentials}. */ public String obtainToken(ClientCredentials credentials) { - return polarisServerManager().accessManager().obtainAccessToken(endpoints, credentials); + return polarisServerManager().accessManager(client).obtainAccessToken(endpoints, credentials); } private boolean ownedName(String name) { diff --git a/integration-tests/src/main/java/org/apache/polaris/service/it/ext/PolarisServerManager.java b/integration-tests/src/main/java/org/apache/polaris/service/it/ext/PolarisServerManager.java index 00cb88284..85e99e0c1 100644 --- a/integration-tests/src/main/java/org/apache/polaris/service/it/ext/PolarisServerManager.java +++ b/integration-tests/src/main/java/org/apache/polaris/service/it/ext/PolarisServerManager.java @@ -51,8 +51,8 @@ public interface PolarisServerManager { */ Server serverForContext(ExtensionContext context); - default PolarisAccessManager accessManager() { - return new IcebergTokenAccessManager(createClient()); + default PolarisAccessManager accessManager(Client client) { + return new IcebergTokenAccessManager(client); } /** Create a new HTTP client for accessing the server targeted by tests. */