Skip to content

Commit c21d17c

Browse files
veloferenc-csaky
authored andcommitted
Add AWS SDK v2 dependencies for Iceberg S3 support (#228)
1 parent 01f54ca commit c21d17c

File tree

3 files changed

+35
-0
lines changed

3 files changed

+35
-0
lines changed

flink-sql-runner/pom.xml

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,28 @@
9090
</exclusions>
9191
</dependency>
9292

93+
<!-- AWS SDK v2 required for Iceberg S3FileIO -->
94+
<dependency>
95+
<groupId>software.amazon.awssdk</groupId>
96+
<artifactId>s3</artifactId>
97+
<version>${aws.sdk.version}</version>
98+
<scope>provided</scope>
99+
</dependency>
100+
101+
<dependency>
102+
<groupId>software.amazon.awssdk</groupId>
103+
<artifactId>sts</artifactId>
104+
<version>${aws.sdk.version}</version>
105+
<scope>provided</scope>
106+
</dependency>
107+
108+
<dependency>
109+
<groupId>software.amazon.awssdk</groupId>
110+
<artifactId>url-connection-client</artifactId>
111+
<version>${aws.sdk.version}</version>
112+
<scope>provided</scope>
113+
</dependency>
114+
93115
<!-- Add logging framework, to produce console output when running in the IDE. -->
94116
<!-- These dependencies are excluded from the application JAR by default. -->
95117
<dependency>
@@ -482,6 +504,17 @@
482504
<outputDirectory>${project.build.directory}</outputDirectory>
483505
</configuration>
484506
</execution>
507+
<execution>
508+
<id>copy-aws-sdk-for-iceberg</id>
509+
<goals>
510+
<goal>copy-dependencies</goal>
511+
</goals>
512+
<phase>process-resources</phase>
513+
<configuration>
514+
<includeGroupIds>software.amazon.awssdk</includeGroupIds>
515+
<outputDirectory>${project.build.directory}/aws-sdk</outputDirectory>
516+
</configuration>
517+
</execution>
485518
<execution>
486519
<id>copy-stdlib-utils</id>
487520
<goals>

flink-sql-runner/src/main/docker/Dockerfile

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ RUN mkdir -p /opt/flink/plugins/flink-sql-runner
2121
COPY flink-s3-fs-hadoop-*.jar /opt/flink/lib
2222
COPY hadoop-hdfs-client-*.jar /opt/flink/lib
2323
COPY iceberg-flink-runtime-*.jar /opt/flink/lib
24+
COPY aws-sdk/*.jar /opt/flink/lib/
2425
COPY stdlib-utils-*.jar /opt/flink/lib
2526
COPY flink-sql-runner.uber.jar /opt/flink/plugins/flink-sql-runner
2627
COPY entrypoint.sh /entrypoint.sh

pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,7 @@
9494
<assertj.version>3.27.4</assertj.version>
9595
<auto.service.version>1.1.1</auto.service.version>
9696
<awaitility.version>4.3.0</awaitility.version>
97+
<aws.sdk.version>2.20.160</aws.sdk.version>
9798
<commons-exec.version>1.5.0</commons-exec.version>
9899
<commons-math3.version>3.6.1</commons-math3.version>
99100
<feign.version>13.5</feign.version>

0 commit comments

Comments
 (0)