Skip to content

Commit f6fd1b9

Browse files
committed
Use official Polaris Catalog docker image
1 parent 6a2b82a commit f6fd1b9

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/rest/TestIcebergPolarisCatalogConnectorSmokeTest.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,11 @@
3333
import java.io.UncheckedIOException;
3434
import java.nio.file.Files;
3535
import java.nio.file.Path;
36+
import java.nio.file.attribute.FileAttribute;
37+
import java.nio.file.attribute.PosixFilePermission;
38+
import java.nio.file.attribute.PosixFilePermissions;
3639
import java.util.Optional;
40+
import java.util.Set;
3741

3842
import static com.google.common.io.MoreFiles.deleteRecursively;
3943
import static com.google.common.io.RecursiveDeleteOption.ALLOW_INSECURE;
@@ -74,7 +78,8 @@ protected boolean hasBehavior(TestingConnectorBehavior connectorBehavior)
7478
protected QueryRunner createQueryRunner()
7579
throws Exception
7680
{
77-
warehouseLocation = Files.createTempDirectory(null);
81+
FileAttribute<Set<PosixFilePermission>> rwx = PosixFilePermissions.asFileAttribute(PosixFilePermissions.fromString("rwxrwxrwx"));
82+
warehouseLocation = Files.createTempDirectory(null, rwx);
7883
polarisCatalog = closeAfterClass(new TestingPolarisCatalog(warehouseLocation.toString()));
7984

8085
return IcebergQueryRunner.builder()

plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/catalog/rest/TestingPolarisCatalog.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@
3535
import static io.airlift.http.client.StaticBodyGenerator.createStaticBodyGenerator;
3636
import static io.airlift.http.client.StatusResponseHandler.createStatusResponseHandler;
3737
import static io.airlift.http.client.StringResponseHandler.createStringResponseHandler;
38-
import static io.trino.testing.TestingProperties.getDockerImagesVersion;
3938
import static java.nio.charset.StandardCharsets.UTF_8;
4039
import static java.util.Objects.requireNonNull;
4140

@@ -57,8 +56,7 @@ public TestingPolarisCatalog(String warehouseLocation)
5756
{
5857
this.warehouseLocation = requireNonNull(warehouseLocation, "warehouseLocation is null");
5958

60-
// TODO: Use the official docker image once Polaris community provides it
61-
polarisCatalog = new GenericContainer<>("ghcr.io/trinodb/testing/polaris-catalog:" + getDockerImagesVersion());
59+
polarisCatalog = new GenericContainer<>("apache/polaris:1.0.0-incubating");
6260
polarisCatalog.addExposedPort(POLARIS_PORT);
6361
polarisCatalog.withFileSystemBind(warehouseLocation, warehouseLocation, BindMode.READ_WRITE);
6462
polarisCatalog.waitingFor(new LogMessageWaitStrategy().withRegEx(".*Apache Polaris Server.* started.*"));

0 commit comments

Comments
 (0)