Merge pull request #10 from aiven/support-1.14

added support for flink 1.14.3
Aiven-Open · Mar 9, 2022 · 4764bbb · 4764bbb
2 parents ddcf6c0 + fd2ba00
commit 4764bbb
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 10 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -1,15 +1,15 @@
 version: "2.2"
 services:
   sql-client:
-    image: ftisiot/flink_sql_cli:1.13.2
+    image: ftisiot/flink_sql_cli:1.14.3
     depends_on:
       - jobmanager
     environment:
       FLINK_JOBMANAGER_HOST: jobmanager
 
 
   jobmanager:
-    image: flink:1.13.2-scala_2.12
+    image: flink:1.14.3-scala_2.12
     ports:
       - "8081:8081"
     command: jobmanager
@@ -21,7 +21,7 @@ services:
       - ./data/:/data
 
   taskmanager:
-    image: flink:1.13.2-scala_2.12
+    image: flink:1.14.3-scala_2.12
     depends_on:
       - jobmanager
     command: taskmanager
@@ -30,7 +30,7 @@ services:
       - |
         FLINK_PROPERTIES=
         jobmanager.rpc.address: jobmanager
-        taskmanager.numberOfTaskSlots: 2
+        taskmanager.numberOfTaskSlots: 10
     volumes:
       - ./settings/:/settings
       - ./data/:/data
diff --git a/sql-client/Dockerfile b/sql-client/Dockerfile
@@ -21,19 +21,20 @@
 #SQL CLI - inspired by https://github.com/wuchong/flink-sql-demo/tree/v1.11-EN/sql-client
 ###############################################################################
 
-FROM flink:1.13.2-scala_2.12
+FROM flink:1.14.3-scala_2.12
 
 # Create CLI lib folder
 COPY bin/* /opt/sql-client/
 RUN mkdir -p /opt/sql-client/lib
 
 # Download connector libraries
-RUN wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7_2.12/1.13.2/flink-sql-connector-elasticsearch7_2.12-1.13.2.jar \
-    wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka_2.12/1.13.2/flink-sql-connector-kafka_2.12-1.13.2.jar; \
-    wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc_2.12/1.13.2/flink-connector-jdbc_2.12-1.13.2.jar; \
+
+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 \
+    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; \
+    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; \
     wget -P /opt/sql-client/lib/ https://jdbc.postgresql.org/download/postgresql-42.2.19.jre6.jar; \
-    wget -P /opt/sql-client/lib/ https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro-confluent-registry/1.13.2/flink-sql-avro-confluent-registry-1.13.2.jar; \
-    wget -P /opt/sql-client/lib/ https://github.com/knaufk/flink-faker/releases/download/v0.4.0/flink-faker-0.4.0.jar;
+    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; \
+    wget -P /opt/sql-client/lib/ https://github.com/knaufk/flink-faker/releases/download/v0.4.1/flink-faker-0.4.1.jar;
 
 # Copy configuration
 COPY conf/* /opt/flink/conf/