diff --git a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeMinioAndHmsConnectorSmokeTest.java b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeMinioAndHmsConnectorSmokeTest.java index 2251f8a88202..d5c83ef50c1a 100644 --- a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeMinioAndHmsConnectorSmokeTest.java +++ b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeMinioAndHmsConnectorSmokeTest.java @@ -50,11 +50,14 @@ public class TestDeltaLakeMinioAndHmsConnectorSmokeTest protected Map hiveStorageConfiguration() { return ImmutableMap.builder() - .put("hive.s3.aws-access-key", MINIO_ACCESS_KEY) - .put("hive.s3.aws-secret-key", MINIO_SECRET_KEY) - .put("hive.s3.endpoint", hiveMinioDataLake.getMinio().getMinioAddress()) - .put("hive.s3.path-style-access", "true") - .put("hive.s3.max-connections", "2") + .put("fs.hadoop.enabled", "false") + .put("fs.native-s3.enabled", "true") + .put("s3.aws-access-key", MINIO_ACCESS_KEY) + .put("s3.aws-secret-key", MINIO_SECRET_KEY) + .put("s3.region", MINIO_REGION) + .put("s3.endpoint", hiveMinioDataLake.getMinio().getMinioAddress()) + .put("s3.path-style-access", "true") + .put("s3.max-connections", "2") .buildOrThrow(); } diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/IcebergQueryRunner.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/IcebergQueryRunner.java index 14ef2d855e0e..24cbcd7b7b04 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/IcebergQueryRunner.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/IcebergQueryRunner.java @@ -47,6 +47,7 @@ import static io.trino.plugin.iceberg.catalog.rest.RestCatalogTestUtils.backendCatalog; import static io.trino.testing.TestingSession.testSessionBuilder; import static io.trino.testing.containers.Minio.MINIO_ACCESS_KEY; +import static io.trino.testing.containers.Minio.MINIO_REGION; import static io.trino.testing.containers.Minio.MINIO_SECRET_KEY; import static java.nio.charset.StandardCharsets.UTF_8; import static java.util.Objects.requireNonNull; @@ -226,11 +227,14 @@ public static void main(String[] args) .setIcebergProperties(Map.of( "iceberg.catalog.type", "HIVE_METASTORE", "hive.metastore.uri", "thrift://" + hiveMinioDataLake.getHiveHadoop().getHiveMetastoreEndpoint(), - "hive.s3.aws-access-key", MINIO_ACCESS_KEY, - "hive.s3.aws-secret-key", MINIO_SECRET_KEY, - "hive.s3.endpoint", hiveMinioDataLake.getMinio().getMinioAddress(), - "hive.s3.path-style-access", "true", - "hive.s3.streaming.part-size", "5MB")) + "fs.hadoop.enabled", "false", + "fs.native-s3.enabled", "true", + "s3.aws-access-key", MINIO_ACCESS_KEY, + "s3.aws-secret-key", MINIO_SECRET_KEY, + "s3.region", MINIO_REGION, + "s3.endpoint", hiveMinioDataLake.getMinio().getMinioAddress(), + "s3.path-style-access", "true", + "s3.streaming.part-size", "5MB")) .setSchemaInitializer( SchemaInitializer.builder() .withSchemaName("tpch") @@ -267,11 +271,14 @@ public static void main(String[] args) .setIcebergProperties(Map.of( "iceberg.catalog.type", "TESTING_FILE_METASTORE", "hive.metastore.catalog.dir", "s3://%s/".formatted(bucketName), - "hive.s3.aws-access-key", MINIO_ACCESS_KEY, - "hive.s3.aws-secret-key", MINIO_SECRET_KEY, - "hive.s3.endpoint", "http://" + minio.getMinioApiEndpoint(), - "hive.s3.path-style-access", "true", - "hive.s3.streaming.part-size", "5MB")) + "fs.hadoop.enabled", "false", + "fs.native-s3.enabled", "true", + "s3.aws-access-key", MINIO_ACCESS_KEY, + "s3.aws-secret-key", MINIO_SECRET_KEY, + "s3.region", MINIO_REGION, + "s3.endpoint", "http://" + minio.getMinioApiEndpoint(), + "s3.path-style-access", "true", + "s3.streaming.part-size", "5MB")) .setSchemaInitializer( SchemaInitializer.builder() .withSchemaName("tpch") diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergReadVersionedTableByTemporal.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergReadVersionedTableByTemporal.java index f03fb453f92a..00e653f71424 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergReadVersionedTableByTemporal.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergReadVersionedTableByTemporal.java @@ -26,6 +26,7 @@ import static io.trino.plugin.iceberg.IcebergQueryRunner.ICEBERG_CATALOG; import static io.trino.testing.TestingNames.randomNameSuffix; import static io.trino.testing.containers.Minio.MINIO_ACCESS_KEY; +import static io.trino.testing.containers.Minio.MINIO_REGION; import static io.trino.testing.containers.Minio.MINIO_SECRET_KEY; import static java.lang.String.format; import static org.assertj.core.api.Assertions.assertThat; @@ -50,10 +51,13 @@ protected QueryRunner createQueryRunner() QueryRunner queryRunner = IcebergQueryRunner.builder() .setIcebergProperties( ImmutableMap.builder() - .put("hive.s3.aws-access-key", MINIO_ACCESS_KEY) - .put("hive.s3.aws-secret-key", MINIO_SECRET_KEY) - .put("hive.s3.endpoint", minio.getMinioAddress()) - .put("hive.s3.path-style-access", "true") + .put("fs.hadoop.enabled", "false") + .put("fs.native-s3.enabled", "true") + .put("s3.aws-access-key", MINIO_ACCESS_KEY) + .put("s3.aws-secret-key", MINIO_SECRET_KEY) + .put("s3.region", MINIO_REGION) + .put("s3.endpoint", minio.getMinioAddress()) + .put("s3.path-style-access", "true") .put("iceberg.register-table-procedure.enabled", "true") .buildOrThrow()) .build();