Skip to content

Commit 2d2724c

Browse files
authored
Merge pull request #16 from aiven/ftisiot-1.15
Added support for Flink 1.15
2 parents b61cc8e + 4511007 commit 2d2724c

File tree

3 files changed

+14
-14
lines changed

3 files changed

+14
-14
lines changed

README.md

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
# SQL CLI for Apache Flink® on Docker®
22

33

4-
This docker-compose provides a Flink SQL CLI image updated to the 1.14.3 version. It's inspired by [this](https://github.com/wuchong/flink-sql-demo/tree/v1.11-EN/sql-client).
4+
This docker-compose provides a Flink SQL CLI image updated to the 1.15.0 version. It's inspired by [this](https://github.com/wuchong/flink-sql-demo/tree/v1.11-EN/sql-client).
55

66

7-
It makes use of the `flink:1.14.3-scala_2.12` images and of the `ftisiot/flink-sql-client:1.14.3` which is based on the same `flink:1.14.3-scala_2.12` image.
7+
It makes use of the `flink:1.15.0-scala_2.12` images and of the `ftisiot/flink-sql-client:1.15.0` which is based on the same `flink:1.15.0-scala_2.12` image.
88

99
The `sql-client` service maps a `~/kafkacerts/` folder to `/certs` which can be used to create and pass files like Keystores when SSL authentication is needed (e.g. with Apache Kafka®).
1010

@@ -55,9 +55,9 @@ And take note of the `CONTAINER_ID` related to the `ftisiot/flink_sql_cli:1.14.3
5555

5656
```
5757
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
58-
af00e6ef943f ftisiot/flink_sql_cli:1.12.0 "/docker-entrypoint.…" 2 minutes ago Up 2 minutes 6123/tcp, 8081/tcp flink_sql-client_1
59-
22a459232385 flink:1.14.3-scala_2.12 "/docker-entrypoint.…" 2 minutes ago Up 2 minutes 6123/tcp, 8081/tcp flink_taskmanager_1
60-
8b4d5c087800 flink:1.14.3-scala_2.12 "/docker-entrypoint.…" 2 minutes ago Up 2 minutes 6123/tcp, 0.0.0.0:8081->8081/tcp flink_jobmanager_1
58+
af00e6ef943f ftisiot/flink_sql_cli:1.15.0 "/docker-entrypoint.…" 2 minutes ago Up 2 minutes 6123/tcp, 8081/tcp flink_sql-client_1
59+
22a459232385 flink:1.15.0-scala_2.12 "/docker-entrypoint.…" 2 minutes ago Up 2 minutes 6123/tcp, 8081/tcp flink_taskmanager_1
60+
8b4d5c087800 flink:1.15.0-scala_2.12 "/docker-entrypoint.…" 2 minutes ago Up 2 minutes 6123/tcp, 0.0.0.0:8081->8081/tcp flink_jobmanager_1
6161
```
6262

6363
Now execute the following code to enter the docker container in interactive mode

docker-compose.yml

+3-3
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
version: "2.2"
22
services:
33
sql-client:
4-
image: ftisiot/flink_sql_cli:1.14.3
4+
image: ftisiot/flink_sql_cli:1.15.0
55
depends_on:
66
- jobmanager
77
environment:
@@ -10,7 +10,7 @@ services:
1010
- ./settings/:/settings
1111

1212
jobmanager:
13-
image: flink:1.14.3-scala_2.12-java8
13+
image: flink:1.15.0-scala_2.12-java11
1414
ports:
1515
- "8081:8081"
1616
command: jobmanager
@@ -23,7 +23,7 @@ services:
2323
- ./data/:/data
2424

2525
taskmanager:
26-
image: flink:1.14.3-scala_2.12-java8
26+
image: flink:1.15.0-scala_2.12-java11
2727
depends_on:
2828
- jobmanager
2929
command: taskmanager

sql-client/Dockerfile

+6-6
Original file line numberDiff line numberDiff line change
@@ -21,19 +21,19 @@
2121
#SQL CLI - inspired by https://github.com/wuchong/flink-sql-demo/tree/v1.11-EN/sql-client
2222
###############################################################################
2323

24-
FROM flink:1.14.3-scala_2.12-java8
24+
FROM flink:1.15.0-scala_2.12-java11
2525

2626
# Create CLI lib folder
2727
COPY bin/* /opt/sql-client/
2828
RUN mkdir -p /opt/sql-client/lib
2929

3030
# Download connector libraries
3131

32-
RUN wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7_2.12/1.14.3/flink-sql-connector-elasticsearch7_2.12-1.14.3.jar; \
33-
wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka_2.12/1.14.3/flink-sql-connector-kafka_2.12-1.14.3.jar; \
34-
wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc_2.12/1.14.3/flink-connector-jdbc_2.12-1.14.3.jar; \
35-
wget -P /opt/sql-client/lib/ https://jdbc.postgresql.org/download/postgresql-42.3.3.jar; \
36-
wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro-confluent-registry/1.14.3/flink-sql-avro-confluent-registry-1.14.3.jar; \
32+
RUN wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/1.15.0/flink-sql-connector-elasticsearch7-1.15.0.jar; \
33+
wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/1.15.0/flink-sql-connector-kafka-1.15.0.jar; \
34+
wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc/1.15.0/flink-connector-jdbc-1.15.0.jar; \
35+
wget -P /opt/sql-client/lib/ https://jdbc.postgresql.org/download/postgresql-42.3.6.jar; \
36+
wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro-confluent-registry/1.15.0/flink-sql-avro-confluent-registry-1.15.0.jar; \
3737
wget -P /opt/sql-client/lib/ https://github.com/knaufk/flink-faker/releases/download/v0.4.1/flink-faker-0.4.1.jar;
3838

3939
# Copy configuration

0 commit comments

Comments
 (0)