This is an automated email from the ASF dual-hosted git repository.
danderson pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-playgrounds.git
The following commit(s) were added to refs/heads/master by this push:
new 7d55cc5 [FLINK-27512][flink-playgrounds] Update pyflink walkthrough
playground for 1.15
7d55cc5 is described below
commit 7d55cc567bb2c064f7ce49ff21faa9486bd3de65
Author: Roy Michael <roy.m...@gmail.com>
AuthorDate: Mon Sep 19 23:51:40 2022 +0300
[FLINK-27512][flink-playgrounds] Update pyflink walkthrough playground for
1.15
1. change flink version to 1.15.2
2. use scala free dependencies
---
pyflink-walkthrough/Dockerfile | 10 +++++-----
pyflink-walkthrough/docker-compose.yml | 4 ++--
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/pyflink-walkthrough/Dockerfile b/pyflink-walkthrough/Dockerfile
index d898ccc..c0364b2 100644
--- a/pyflink-walkthrough/Dockerfile
+++ b/pyflink-walkthrough/Dockerfile
@@ -20,8 +20,8 @@
# Build PyFlink Playground Image
###############################################################################
-FROM apache/flink:1.14.4-scala_2.12-java8
-ARG FLINK_VERSION=1.14.4
+FROM apache/flink:1.15.2-scala_2.12-java8
+ARG FLINK_VERSION=1.15.2
# Install python3.7 and pyflink
# Pyflink does not yet function with python3.9, and this image is build on
@@ -42,13 +42,13 @@ RUN set -ex; \
apt-get clean && \
rm -rf /var/lib/apt/lists/* && \
python -m pip install --upgrade pip; \
- pip install apache-flink==1.14.4; \
+ pip install apache-flink==1.15.2; \
pip install kafka-python;
# Download connector libraries
RUN wget -P /opt/flink/lib/
https://repo.maven.apache.org/maven2/org/apache/flink/flink-json/${FLINK_VERSION}/flink-json-${FLINK_VERSION}.jar;
\
- wget -P /opt/flink/lib/
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka_2.12/${FLINK_VERSION}/flink-sql-connector-kafka_2.12-${FLINK_VERSION}.jar;
\
- wget -P /opt/flink/lib/
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7_2.12/${FLINK_VERSION}/flink-sql-connector-elasticsearch7_2.12-${FLINK_VERSION}.jar;
+ wget -P /opt/flink/lib/
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-kafka/${FLINK_VERSION}/flink-sql-connector-kafka-${FLINK_VERSION}.jar;
\
+ wget -P /opt/flink/lib/
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch7/${FLINK_VERSION}/flink-sql-connector-elasticsearch7-${FLINK_VERSION}.jar;
RUN echo "taskmanager.memory.jvm-metaspace.size: 512m" >>
/opt/flink/conf/flink-conf.yaml;
diff --git a/pyflink-walkthrough/docker-compose.yml
b/pyflink-walkthrough/docker-compose.yml
index 35d7996..3defab8 100644
--- a/pyflink-walkthrough/docker-compose.yml
+++ b/pyflink-walkthrough/docker-compose.yml
@@ -20,7 +20,7 @@ version: '2.1'
services:
jobmanager:
build: .
- image: pyflink/pyflink:1.14.4-scala_2.12
+ image: pyflink/pyflink:1.15.2-scala_2.12
volumes:
- .:/opt/pyflink-walkthrough
hostname: "jobmanager"
@@ -32,7 +32,7 @@ services:
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
taskmanager:
- image: pyflink/pyflink:1.14.4-scala_2.12
+ image: pyflink/pyflink:1.15.2-scala_2.12
volumes:
- .:/opt/pyflink-walkthrough
expose:
