Skip to content

Commit

Permalink
Update Azure & AWS SDKs in exchange filesystem
Browse files Browse the repository at this point in the history
  • Loading branch information
wendigo committed Apr 24, 2023
1 parent 593b4aa commit 33f73cd
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 7 deletions.
4 changes: 2 additions & 2 deletions plugin/trino-delta-lake/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -362,7 +362,7 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core</artifactId>
<version>1.25.0</version>
<version>1.37.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
Expand All @@ -379,7 +379,7 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-storage-blob</artifactId>
<version>12.14.4</version>
<version>12.21.1</version>
<scope>test</scope>
</dependency>

Expand Down
8 changes: 4 additions & 4 deletions plugin/trino-exchange-filesystem/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -14,8 +14,8 @@

<properties>
<air.main.basedir>${project.parent.basedir}</air.main.basedir>
<awsjavasdk.version>2.17.151</awsjavasdk.version>
<azurejavasdk.version>1.1.1</azurejavasdk.version>
<awsjavasdk.version>2.20.48</awsjavasdk.version>
<azurejavasdk.version>1.2.11</azurejavasdk.version>
</properties>

<dependencyManagement>
Expand Down Expand Up @@ -220,7 +220,7 @@
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-core</artifactId>
<version>3.4.13</version>
<version>3.4.27</version>
</dependency>

<dependency>
Expand All @@ -241,7 +241,7 @@
<dependency>
<groupId>org.reactivestreams</groupId>
<artifactId>reactive-streams</artifactId>
<version>1.0.3</version>
<version>1.0.4</version>
</dependency>

<dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,6 +58,7 @@ public void start()
.endpointOverride(URI.create("http://localhost:" + minio.getMinioApiEndpoint().getPort()))
.credentialsProvider(StaticCredentialsProvider.create(AwsBasicCredentials.create(ACCESS_KEY, SECRET_KEY)))
.region(US_EAST_1)
.forcePathStyle(true)
.build();
CreateBucketRequest createBucketRequest = CreateBucketRequest.builder()
.bucket(bucketName)
Expand Down Expand Up @@ -92,6 +93,7 @@ public static Map<String, String> getExchangeManagerProperties(MinioStorage mini
.put("exchange.s3.aws-access-key", MinioStorage.ACCESS_KEY)
.put("exchange.s3.aws-secret-key", MinioStorage.SECRET_KEY)
.put("exchange.s3.region", "us-east-1")
.put("exchange.s3.path-style-access", "true")
.put("exchange.s3.endpoint", "http://" + minioStorage.getMinio().getMinioApiEndpoint())
// create more granular source handles given the fault-tolerant execution target task input size is set to lower value for testing
.put("exchange.source-handle-target-data-size", "1MB")
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@
<dep.iceberg.version>1.2.1</dep.iceberg.version>
<dep.protobuf.version>3.22.2</dep.protobuf.version>
<dep.wire.version>4.5.0</dep.wire.version>
<dep.netty.version>4.1.79.Final</dep.netty.version>
<dep.netty.version>4.1.91.Final</dep.netty.version>
<dep.jna.version>5.13.0</dep.jna.version>

<dep.docker.images.version>79</dep.docker.images.version>
Expand Down

0 comments on commit 33f73cd

Please sign in to comment.