You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2024/02/09 11:21:02 UTC
(flink-docker) branch FLINK-34282-master created (now 5c5a650)
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch FLINK-34282-master
in repository https://gitbox.apache.org/repos/asf/flink-docker.git
at 5c5a650 [hotfix][release] Removes 1.15 and 1.16 as part of the 1.19.0 release preparations
This branch includes the following new commits:
new d448f54 [FLINK-34282][docker] Updates snapshot workflow to consider the dev-1.19 branch and new dev-master.
new 5c5a650 [hotfix][release] Removes 1.15 and 1.16 as part of the 1.19.0 release preparations
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(flink-docker) 02/02: [hotfix][release] Removes 1.15 and 1.16 as part of the 1.19.0 release preparations
Posted by ma...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch FLINK-34282-master
in repository https://gitbox.apache.org/repos/asf/flink-docker.git
commit 5c5a650744a8d69eae65290b65c5331647deab16
Author: Matthias Pohl <ma...@aiven.io>
AuthorDate: Fri Feb 9 12:10:07 2024 +0100
[hotfix][release] Removes 1.15 and 1.16 as part of the 1.19.0 release
preparations
- 1.15 and 1.16 are already deprecated
- 1.17 is kept because we still might do a final patch release as part
of the 1.19.0 release
---
.github/workflows/snapshot.yml | 2 -
1.15/scala_2.12-java11-ubuntu/Dockerfile | 94 -------------
1.15/scala_2.12-java11-ubuntu/docker-entrypoint.sh | 152 ---------------------
1.15/scala_2.12-java11-ubuntu/release.metadata | 2 -
1.15/scala_2.12-java8-ubuntu/Dockerfile | 94 -------------
1.15/scala_2.12-java8-ubuntu/docker-entrypoint.sh | 152 ---------------------
1.15/scala_2.12-java8-ubuntu/release.metadata | 2 -
1.16/scala_2.12-java11-ubuntu/Dockerfile | 94 -------------
1.16/scala_2.12-java11-ubuntu/docker-entrypoint.sh | 152 ---------------------
1.16/scala_2.12-java11-ubuntu/release.metadata | 2 -
1.16/scala_2.12-java8-ubuntu/Dockerfile | 94 -------------
1.16/scala_2.12-java8-ubuntu/docker-entrypoint.sh | 152 ---------------------
1.16/scala_2.12-java8-ubuntu/release.metadata | 2 -
13 files changed, 994 deletions(-)
diff --git a/.github/workflows/snapshot.yml b/.github/workflows/snapshot.yml
index 3d66cd7..2389cd1 100644
--- a/.github/workflows/snapshot.yml
+++ b/.github/workflows/snapshot.yml
@@ -46,8 +46,6 @@ jobs:
branch: dev-1.18
- flink_version: 1.17-SNAPSHOT
branch: dev-1.17
- - flink_version: 1.16-SNAPSHOT
- branch: dev-1.16
steps:
- uses: actions/checkout@v3
with:
diff --git a/1.15/scala_2.12-java11-ubuntu/Dockerfile b/1.15/scala_2.12-java11-ubuntu/Dockerfile
deleted file mode 100644
index 2f38d26..0000000
--- a/1.15/scala_2.12-java11-ubuntu/Dockerfile
+++ /dev/null
@@ -1,94 +0,0 @@
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-FROM eclipse-temurin:11-jre-jammy
-
-# Install dependencies
-RUN set -ex; \
- apt-get update; \
- apt-get -y install gpg libsnappy1v5 gettext-base libjemalloc-dev; \
- rm -rf /var/lib/apt/lists/*
-
-# Grab gosu for easy step-down from root
-ENV GOSU_VERSION 1.11
-RUN set -ex; \
- wget -nv -O /usr/local/bin/gosu "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture)"; \
- wget -nv -O /usr/local/bin/gosu.asc "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture).asc"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys B42F6819007F00F88E364FD4036A9C25BF357DD4 && break || : ; \
- done && \
- gpg --batch --verify /usr/local/bin/gosu.asc /usr/local/bin/gosu; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" /usr/local/bin/gosu.asc; \
- chmod +x /usr/local/bin/gosu; \
- gosu nobody true
-
-# Configure Flink version
-ENV FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download&filename=flink/flink-1.15.4/flink-1.15.4-bin-scala_2.12.tgz \
- FLINK_ASC_URL=https://downloads.apache.org/flink/flink-1.15.4/flink-1.15.4-bin-scala_2.12.tgz.asc \
- GPG_KEY=0F79F2AFB2351BC29678544591F9C1EC125FD8DB \
- CHECK_GPG=true
-
-# Prepare environment
-ENV FLINK_HOME=/opt/flink
-ENV PATH=$FLINK_HOME/bin:$PATH
-RUN groupadd --system --gid=9999 flink && \
- useradd --system --home-dir $FLINK_HOME --uid=9999 --gid=flink flink
-WORKDIR $FLINK_HOME
-
-# Install Flink
-RUN set -ex; \
- wget -nv -O flink.tgz "$FLINK_TGZ_URL"; \
- \
- if [ "$CHECK_GPG" = "true" ]; then \
- wget -nv -O flink.tgz.asc "$FLINK_ASC_URL"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys "$GPG_KEY" && break || : ; \
- done && \
- gpg --batch --verify flink.tgz.asc flink.tgz; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" flink.tgz.asc; \
- fi; \
- \
- tar -xf flink.tgz --strip-components=1; \
- rm flink.tgz; \
- \
- chown -R flink:flink .; \
- \
- # Replace default REST/RPC endpoint bind address to use the container's network interface \
- sed -i 's/rest.address: localhost/rest.address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/rest.bind-address: localhost/rest.bind-address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/jobmanager.bind-host: localhost/jobmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/taskmanager.bind-host: localhost/taskmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i '/taskmanager.host: localhost/d' $FLINK_HOME/conf/flink-conf.yaml;
-
-# Configure container
-COPY docker-entrypoint.sh /
-ENTRYPOINT ["/docker-entrypoint.sh"]
-EXPOSE 6123 8081
-CMD ["help"]
diff --git a/1.15/scala_2.12-java11-ubuntu/docker-entrypoint.sh b/1.15/scala_2.12-java11-ubuntu/docker-entrypoint.sh
deleted file mode 100755
index 8b0350e..0000000
--- a/1.15/scala_2.12-java11-ubuntu/docker-entrypoint.sh
+++ /dev/null
@@ -1,152 +0,0 @@
-#!/usr/bin/env bash
-
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-COMMAND_STANDALONE="standalone-job"
-COMMAND_HISTORY_SERVER="history-server"
-
-# If unspecified, the hostname of the container is taken as the JobManager address
-JOB_MANAGER_RPC_ADDRESS=${JOB_MANAGER_RPC_ADDRESS:-$(hostname -f)}
-CONF_FILE="${FLINK_HOME}/conf/flink-conf.yaml"
-
-drop_privs_cmd() {
- if [ $(id -u) != 0 ]; then
- # Don't need to drop privs if EUID != 0
- return
- elif [ -x /sbin/su-exec ]; then
- # Alpine
- echo su-exec flink
- else
- # Others
- echo gosu flink
- fi
-}
-
-copy_plugins_if_required() {
- if [ -z "$ENABLE_BUILT_IN_PLUGINS" ]; then
- return 0
- fi
-
- echo "Enabling required built-in plugins"
- for target_plugin in $(echo "$ENABLE_BUILT_IN_PLUGINS" | tr ';' ' '); do
- echo "Linking ${target_plugin} to plugin directory"
- plugin_name=${target_plugin%.jar}
-
- mkdir -p "${FLINK_HOME}/plugins/${plugin_name}"
- if [ ! -e "${FLINK_HOME}/opt/${target_plugin}" ]; then
- echo "Plugin ${target_plugin} does not exist. Exiting."
- exit 1
- else
- ln -fs "${FLINK_HOME}/opt/${target_plugin}" "${FLINK_HOME}/plugins/${plugin_name}"
- echo "Successfully enabled ${target_plugin}"
- fi
- done
-}
-
-set_config_option() {
- local option=$1
- local value=$2
-
- # escape periods for usage in regular expressions
- local escaped_option=$(echo ${option} | sed -e "s/\./\\\./g")
-
- # either override an existing entry, or append a new one
- if grep -E "^${escaped_option}:.*" "${CONF_FILE}" > /dev/null; then
- sed -i -e "s/${escaped_option}:.*/$option: $value/g" "${CONF_FILE}"
- else
- echo "${option}: ${value}" >> "${CONF_FILE}"
- fi
-}
-
-prepare_configuration() {
- set_config_option jobmanager.rpc.address ${JOB_MANAGER_RPC_ADDRESS}
- set_config_option blob.server.port 6124
- set_config_option query.server.port 6125
-
- if [ -n "${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}" ]; then
- set_config_option taskmanager.numberOfTaskSlots ${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}
- fi
-
- if [ -n "${FLINK_PROPERTIES}" ]; then
- echo "${FLINK_PROPERTIES}" >> "${CONF_FILE}"
- fi
- envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF_FILE}.tmp" "${CONF_FILE}"
-}
-
-maybe_enable_jemalloc() {
- if [ "${DISABLE_JEMALLOC:-false}" == "false" ]; then
- JEMALLOC_PATH="/usr/lib/$(uname -m)-linux-gnu/libjemalloc.so"
- JEMALLOC_FALLBACK="/usr/lib/x86_64-linux-gnu/libjemalloc.so"
- if [ -f "$JEMALLOC_PATH" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_PATH
- elif [ -f "$JEMALLOC_FALLBACK" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_FALLBACK
- else
- if [ "$JEMALLOC_PATH" = "$JEMALLOC_FALLBACK" ]; then
- MSG_PATH=$JEMALLOC_PATH
- else
- MSG_PATH="$JEMALLOC_PATH and $JEMALLOC_FALLBACK"
- fi
- echo "WARNING: attempted to load jemalloc from $MSG_PATH but the library couldn't be found. glibc will be used instead."
- fi
- fi
-}
-
-maybe_enable_jemalloc
-
-copy_plugins_if_required
-
-prepare_configuration
-
-args=("$@")
-if [ "$1" = "help" ]; then
- printf "Usage: $(basename "$0") (jobmanager|${COMMAND_STANDALONE}|taskmanager|${COMMAND_HISTORY_SERVER})\n"
- printf " Or $(basename "$0") help\n\n"
- printf "By default, Flink image adopts jemalloc as default memory allocator. This behavior can be disabled by setting the 'DISABLE_JEMALLOC' environment variable to 'true'.\n"
- exit 0
-elif [ "$1" = "jobmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/jobmanager.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_STANDALONE} ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/standalone-job.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_HISTORY_SERVER} ]; then
- args=("${args[@]:1}")
-
- echo "Starting History Server"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/historyserver.sh" start-foreground "${args[@]}"
-elif [ "$1" = "taskmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Task Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/taskmanager.sh" start-foreground "${args[@]}"
-fi
-
-args=("${args[@]}")
-
-# Running command in pass-through mode
-exec $(drop_privs_cmd) "${args[@]}"
diff --git a/1.15/scala_2.12-java11-ubuntu/release.metadata b/1.15/scala_2.12-java11-ubuntu/release.metadata
deleted file mode 100644
index 25d5dfe..0000000
--- a/1.15/scala_2.12-java11-ubuntu/release.metadata
+++ /dev/null
@@ -1,2 +0,0 @@
-Tags: 1.15.4-scala_2.12-java11, 1.15-scala_2.12-java11, scala_2.12-java11, 1.15.4-scala_2.12, 1.15-scala_2.12, scala_2.12, 1.15.4-java11, 1.15-java11, java11, 1.15.4, 1.15, latest
-Architectures: amd64,arm64v8
diff --git a/1.15/scala_2.12-java8-ubuntu/Dockerfile b/1.15/scala_2.12-java8-ubuntu/Dockerfile
deleted file mode 100644
index 50bafa4..0000000
--- a/1.15/scala_2.12-java8-ubuntu/Dockerfile
+++ /dev/null
@@ -1,94 +0,0 @@
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-FROM eclipse-temurin:8-jre-jammy
-
-# Install dependencies
-RUN set -ex; \
- apt-get update; \
- apt-get -y install gpg libsnappy1v5 gettext-base libjemalloc-dev; \
- rm -rf /var/lib/apt/lists/*
-
-# Grab gosu for easy step-down from root
-ENV GOSU_VERSION 1.11
-RUN set -ex; \
- wget -nv -O /usr/local/bin/gosu "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture)"; \
- wget -nv -O /usr/local/bin/gosu.asc "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture).asc"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys B42F6819007F00F88E364FD4036A9C25BF357DD4 && break || : ; \
- done && \
- gpg --batch --verify /usr/local/bin/gosu.asc /usr/local/bin/gosu; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" /usr/local/bin/gosu.asc; \
- chmod +x /usr/local/bin/gosu; \
- gosu nobody true
-
-# Configure Flink version
-ENV FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download&filename=flink/flink-1.15.4/flink-1.15.4-bin-scala_2.12.tgz \
- FLINK_ASC_URL=https://downloads.apache.org/flink/flink-1.15.4/flink-1.15.4-bin-scala_2.12.tgz.asc \
- GPG_KEY=0F79F2AFB2351BC29678544591F9C1EC125FD8DB \
- CHECK_GPG=true
-
-# Prepare environment
-ENV FLINK_HOME=/opt/flink
-ENV PATH=$FLINK_HOME/bin:$PATH
-RUN groupadd --system --gid=9999 flink && \
- useradd --system --home-dir $FLINK_HOME --uid=9999 --gid=flink flink
-WORKDIR $FLINK_HOME
-
-# Install Flink
-RUN set -ex; \
- wget -nv -O flink.tgz "$FLINK_TGZ_URL"; \
- \
- if [ "$CHECK_GPG" = "true" ]; then \
- wget -nv -O flink.tgz.asc "$FLINK_ASC_URL"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys "$GPG_KEY" && break || : ; \
- done && \
- gpg --batch --verify flink.tgz.asc flink.tgz; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" flink.tgz.asc; \
- fi; \
- \
- tar -xf flink.tgz --strip-components=1; \
- rm flink.tgz; \
- \
- chown -R flink:flink .; \
- \
- # Replace default REST/RPC endpoint bind address to use the container's network interface \
- sed -i 's/rest.address: localhost/rest.address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/rest.bind-address: localhost/rest.bind-address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/jobmanager.bind-host: localhost/jobmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/taskmanager.bind-host: localhost/taskmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i '/taskmanager.host: localhost/d' $FLINK_HOME/conf/flink-conf.yaml;
-
-# Configure container
-COPY docker-entrypoint.sh /
-ENTRYPOINT ["/docker-entrypoint.sh"]
-EXPOSE 6123 8081
-CMD ["help"]
diff --git a/1.15/scala_2.12-java8-ubuntu/docker-entrypoint.sh b/1.15/scala_2.12-java8-ubuntu/docker-entrypoint.sh
deleted file mode 100755
index 8b0350e..0000000
--- a/1.15/scala_2.12-java8-ubuntu/docker-entrypoint.sh
+++ /dev/null
@@ -1,152 +0,0 @@
-#!/usr/bin/env bash
-
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-COMMAND_STANDALONE="standalone-job"
-COMMAND_HISTORY_SERVER="history-server"
-
-# If unspecified, the hostname of the container is taken as the JobManager address
-JOB_MANAGER_RPC_ADDRESS=${JOB_MANAGER_RPC_ADDRESS:-$(hostname -f)}
-CONF_FILE="${FLINK_HOME}/conf/flink-conf.yaml"
-
-drop_privs_cmd() {
- if [ $(id -u) != 0 ]; then
- # Don't need to drop privs if EUID != 0
- return
- elif [ -x /sbin/su-exec ]; then
- # Alpine
- echo su-exec flink
- else
- # Others
- echo gosu flink
- fi
-}
-
-copy_plugins_if_required() {
- if [ -z "$ENABLE_BUILT_IN_PLUGINS" ]; then
- return 0
- fi
-
- echo "Enabling required built-in plugins"
- for target_plugin in $(echo "$ENABLE_BUILT_IN_PLUGINS" | tr ';' ' '); do
- echo "Linking ${target_plugin} to plugin directory"
- plugin_name=${target_plugin%.jar}
-
- mkdir -p "${FLINK_HOME}/plugins/${plugin_name}"
- if [ ! -e "${FLINK_HOME}/opt/${target_plugin}" ]; then
- echo "Plugin ${target_plugin} does not exist. Exiting."
- exit 1
- else
- ln -fs "${FLINK_HOME}/opt/${target_plugin}" "${FLINK_HOME}/plugins/${plugin_name}"
- echo "Successfully enabled ${target_plugin}"
- fi
- done
-}
-
-set_config_option() {
- local option=$1
- local value=$2
-
- # escape periods for usage in regular expressions
- local escaped_option=$(echo ${option} | sed -e "s/\./\\\./g")
-
- # either override an existing entry, or append a new one
- if grep -E "^${escaped_option}:.*" "${CONF_FILE}" > /dev/null; then
- sed -i -e "s/${escaped_option}:.*/$option: $value/g" "${CONF_FILE}"
- else
- echo "${option}: ${value}" >> "${CONF_FILE}"
- fi
-}
-
-prepare_configuration() {
- set_config_option jobmanager.rpc.address ${JOB_MANAGER_RPC_ADDRESS}
- set_config_option blob.server.port 6124
- set_config_option query.server.port 6125
-
- if [ -n "${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}" ]; then
- set_config_option taskmanager.numberOfTaskSlots ${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}
- fi
-
- if [ -n "${FLINK_PROPERTIES}" ]; then
- echo "${FLINK_PROPERTIES}" >> "${CONF_FILE}"
- fi
- envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF_FILE}.tmp" "${CONF_FILE}"
-}
-
-maybe_enable_jemalloc() {
- if [ "${DISABLE_JEMALLOC:-false}" == "false" ]; then
- JEMALLOC_PATH="/usr/lib/$(uname -m)-linux-gnu/libjemalloc.so"
- JEMALLOC_FALLBACK="/usr/lib/x86_64-linux-gnu/libjemalloc.so"
- if [ -f "$JEMALLOC_PATH" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_PATH
- elif [ -f "$JEMALLOC_FALLBACK" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_FALLBACK
- else
- if [ "$JEMALLOC_PATH" = "$JEMALLOC_FALLBACK" ]; then
- MSG_PATH=$JEMALLOC_PATH
- else
- MSG_PATH="$JEMALLOC_PATH and $JEMALLOC_FALLBACK"
- fi
- echo "WARNING: attempted to load jemalloc from $MSG_PATH but the library couldn't be found. glibc will be used instead."
- fi
- fi
-}
-
-maybe_enable_jemalloc
-
-copy_plugins_if_required
-
-prepare_configuration
-
-args=("$@")
-if [ "$1" = "help" ]; then
- printf "Usage: $(basename "$0") (jobmanager|${COMMAND_STANDALONE}|taskmanager|${COMMAND_HISTORY_SERVER})\n"
- printf " Or $(basename "$0") help\n\n"
- printf "By default, Flink image adopts jemalloc as default memory allocator. This behavior can be disabled by setting the 'DISABLE_JEMALLOC' environment variable to 'true'.\n"
- exit 0
-elif [ "$1" = "jobmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/jobmanager.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_STANDALONE} ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/standalone-job.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_HISTORY_SERVER} ]; then
- args=("${args[@]:1}")
-
- echo "Starting History Server"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/historyserver.sh" start-foreground "${args[@]}"
-elif [ "$1" = "taskmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Task Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/taskmanager.sh" start-foreground "${args[@]}"
-fi
-
-args=("${args[@]}")
-
-# Running command in pass-through mode
-exec $(drop_privs_cmd) "${args[@]}"
diff --git a/1.15/scala_2.12-java8-ubuntu/release.metadata b/1.15/scala_2.12-java8-ubuntu/release.metadata
deleted file mode 100644
index cc69847..0000000
--- a/1.15/scala_2.12-java8-ubuntu/release.metadata
+++ /dev/null
@@ -1,2 +0,0 @@
-Tags: 1.15.4-scala_2.12-java8, 1.15-scala_2.12-java8, scala_2.12-java8, 1.15.4-java8, 1.15-java8, java8
-Architectures: amd64,arm64v8
diff --git a/1.16/scala_2.12-java11-ubuntu/Dockerfile b/1.16/scala_2.12-java11-ubuntu/Dockerfile
deleted file mode 100644
index 08c808b..0000000
--- a/1.16/scala_2.12-java11-ubuntu/Dockerfile
+++ /dev/null
@@ -1,94 +0,0 @@
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-FROM eclipse-temurin:11-jre-jammy
-
-# Install dependencies
-RUN set -ex; \
- apt-get update; \
- apt-get -y install gpg libsnappy1v5 gettext-base libjemalloc-dev; \
- rm -rf /var/lib/apt/lists/*
-
-# Grab gosu for easy step-down from root
-ENV GOSU_VERSION 1.11
-RUN set -ex; \
- wget -nv -O /usr/local/bin/gosu "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture)"; \
- wget -nv -O /usr/local/bin/gosu.asc "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture).asc"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys B42F6819007F00F88E364FD4036A9C25BF357DD4 && break || : ; \
- done && \
- gpg --batch --verify /usr/local/bin/gosu.asc /usr/local/bin/gosu; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" /usr/local/bin/gosu.asc; \
- chmod +x /usr/local/bin/gosu; \
- gosu nobody true
-
-# Configure Flink version
-ENV FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download&filename=flink/flink-1.16.3/flink-1.16.3-bin-scala_2.12.tgz \
- FLINK_ASC_URL=https://downloads.apache.org/flink/flink-1.16.3/flink-1.16.3-bin-scala_2.12.tgz.asc \
- GPG_KEY=B2D64016B940A7E0B9B72E0D7D0528B28037D8BC \
- CHECK_GPG=true
-
-# Prepare environment
-ENV FLINK_HOME=/opt/flink
-ENV PATH=$FLINK_HOME/bin:$PATH
-RUN groupadd --system --gid=9999 flink && \
- useradd --system --home-dir $FLINK_HOME --uid=9999 --gid=flink flink
-WORKDIR $FLINK_HOME
-
-# Install Flink
-RUN set -ex; \
- wget -nv -O flink.tgz "$FLINK_TGZ_URL"; \
- \
- if [ "$CHECK_GPG" = "true" ]; then \
- wget -nv -O flink.tgz.asc "$FLINK_ASC_URL"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys "$GPG_KEY" && break || : ; \
- done && \
- gpg --batch --verify flink.tgz.asc flink.tgz; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" flink.tgz.asc; \
- fi; \
- \
- tar -xf flink.tgz --strip-components=1; \
- rm flink.tgz; \
- \
- chown -R flink:flink .; \
- \
- # Replace default REST/RPC endpoint bind address to use the container's network interface \
- sed -i 's/rest.address: localhost/rest.address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/rest.bind-address: localhost/rest.bind-address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/jobmanager.bind-host: localhost/jobmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/taskmanager.bind-host: localhost/taskmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i '/taskmanager.host: localhost/d' $FLINK_HOME/conf/flink-conf.yaml;
-
-# Configure container
-COPY docker-entrypoint.sh /
-ENTRYPOINT ["/docker-entrypoint.sh"]
-EXPOSE 6123 8081
-CMD ["help"]
diff --git a/1.16/scala_2.12-java11-ubuntu/docker-entrypoint.sh b/1.16/scala_2.12-java11-ubuntu/docker-entrypoint.sh
deleted file mode 100755
index 8b0350e..0000000
--- a/1.16/scala_2.12-java11-ubuntu/docker-entrypoint.sh
+++ /dev/null
@@ -1,152 +0,0 @@
-#!/usr/bin/env bash
-
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-COMMAND_STANDALONE="standalone-job"
-COMMAND_HISTORY_SERVER="history-server"
-
-# If unspecified, the hostname of the container is taken as the JobManager address
-JOB_MANAGER_RPC_ADDRESS=${JOB_MANAGER_RPC_ADDRESS:-$(hostname -f)}
-CONF_FILE="${FLINK_HOME}/conf/flink-conf.yaml"
-
-drop_privs_cmd() {
- if [ $(id -u) != 0 ]; then
- # Don't need to drop privs if EUID != 0
- return
- elif [ -x /sbin/su-exec ]; then
- # Alpine
- echo su-exec flink
- else
- # Others
- echo gosu flink
- fi
-}
-
-copy_plugins_if_required() {
- if [ -z "$ENABLE_BUILT_IN_PLUGINS" ]; then
- return 0
- fi
-
- echo "Enabling required built-in plugins"
- for target_plugin in $(echo "$ENABLE_BUILT_IN_PLUGINS" | tr ';' ' '); do
- echo "Linking ${target_plugin} to plugin directory"
- plugin_name=${target_plugin%.jar}
-
- mkdir -p "${FLINK_HOME}/plugins/${plugin_name}"
- if [ ! -e "${FLINK_HOME}/opt/${target_plugin}" ]; then
- echo "Plugin ${target_plugin} does not exist. Exiting."
- exit 1
- else
- ln -fs "${FLINK_HOME}/opt/${target_plugin}" "${FLINK_HOME}/plugins/${plugin_name}"
- echo "Successfully enabled ${target_plugin}"
- fi
- done
-}
-
-set_config_option() {
- local option=$1
- local value=$2
-
- # escape periods for usage in regular expressions
- local escaped_option=$(echo ${option} | sed -e "s/\./\\\./g")
-
- # either override an existing entry, or append a new one
- if grep -E "^${escaped_option}:.*" "${CONF_FILE}" > /dev/null; then
- sed -i -e "s/${escaped_option}:.*/$option: $value/g" "${CONF_FILE}"
- else
- echo "${option}: ${value}" >> "${CONF_FILE}"
- fi
-}
-
-prepare_configuration() {
- set_config_option jobmanager.rpc.address ${JOB_MANAGER_RPC_ADDRESS}
- set_config_option blob.server.port 6124
- set_config_option query.server.port 6125
-
- if [ -n "${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}" ]; then
- set_config_option taskmanager.numberOfTaskSlots ${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}
- fi
-
- if [ -n "${FLINK_PROPERTIES}" ]; then
- echo "${FLINK_PROPERTIES}" >> "${CONF_FILE}"
- fi
- envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF_FILE}.tmp" "${CONF_FILE}"
-}
-
-maybe_enable_jemalloc() {
- if [ "${DISABLE_JEMALLOC:-false}" == "false" ]; then
- JEMALLOC_PATH="/usr/lib/$(uname -m)-linux-gnu/libjemalloc.so"
- JEMALLOC_FALLBACK="/usr/lib/x86_64-linux-gnu/libjemalloc.so"
- if [ -f "$JEMALLOC_PATH" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_PATH
- elif [ -f "$JEMALLOC_FALLBACK" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_FALLBACK
- else
- if [ "$JEMALLOC_PATH" = "$JEMALLOC_FALLBACK" ]; then
- MSG_PATH=$JEMALLOC_PATH
- else
- MSG_PATH="$JEMALLOC_PATH and $JEMALLOC_FALLBACK"
- fi
- echo "WARNING: attempted to load jemalloc from $MSG_PATH but the library couldn't be found. glibc will be used instead."
- fi
- fi
-}
-
-maybe_enable_jemalloc
-
-copy_plugins_if_required
-
-prepare_configuration
-
-args=("$@")
-if [ "$1" = "help" ]; then
- printf "Usage: $(basename "$0") (jobmanager|${COMMAND_STANDALONE}|taskmanager|${COMMAND_HISTORY_SERVER})\n"
- printf " Or $(basename "$0") help\n\n"
- printf "By default, Flink image adopts jemalloc as default memory allocator. This behavior can be disabled by setting the 'DISABLE_JEMALLOC' environment variable to 'true'.\n"
- exit 0
-elif [ "$1" = "jobmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/jobmanager.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_STANDALONE} ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/standalone-job.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_HISTORY_SERVER} ]; then
- args=("${args[@]:1}")
-
- echo "Starting History Server"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/historyserver.sh" start-foreground "${args[@]}"
-elif [ "$1" = "taskmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Task Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/taskmanager.sh" start-foreground "${args[@]}"
-fi
-
-args=("${args[@]}")
-
-# Running command in pass-through mode
-exec $(drop_privs_cmd) "${args[@]}"
diff --git a/1.16/scala_2.12-java11-ubuntu/release.metadata b/1.16/scala_2.12-java11-ubuntu/release.metadata
deleted file mode 100644
index 65b1511..0000000
--- a/1.16/scala_2.12-java11-ubuntu/release.metadata
+++ /dev/null
@@ -1,2 +0,0 @@
-Tags: 1.16.3-scala_2.12-java11, 1.16-scala_2.12-java11, scala_2.12-java11, 1.16.3-scala_2.12, 1.16-scala_2.12, scala_2.12, 1.16.3-java11, 1.16-java11, java11, 1.16.3, 1.16, latest
-Architectures: amd64,arm64v8
diff --git a/1.16/scala_2.12-java8-ubuntu/Dockerfile b/1.16/scala_2.12-java8-ubuntu/Dockerfile
deleted file mode 100644
index d7761af..0000000
--- a/1.16/scala_2.12-java8-ubuntu/Dockerfile
+++ /dev/null
@@ -1,94 +0,0 @@
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-FROM eclipse-temurin:8-jre-jammy
-
-# Install dependencies
-RUN set -ex; \
- apt-get update; \
- apt-get -y install gpg libsnappy1v5 gettext-base libjemalloc-dev; \
- rm -rf /var/lib/apt/lists/*
-
-# Grab gosu for easy step-down from root
-ENV GOSU_VERSION 1.11
-RUN set -ex; \
- wget -nv -O /usr/local/bin/gosu "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture)"; \
- wget -nv -O /usr/local/bin/gosu.asc "https://github.com/tianon/gosu/releases/download/$GOSU_VERSION/gosu-$(dpkg --print-architecture).asc"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys B42F6819007F00F88E364FD4036A9C25BF357DD4 && break || : ; \
- done && \
- gpg --batch --verify /usr/local/bin/gosu.asc /usr/local/bin/gosu; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" /usr/local/bin/gosu.asc; \
- chmod +x /usr/local/bin/gosu; \
- gosu nobody true
-
-# Configure Flink version
-ENV FLINK_TGZ_URL=https://www.apache.org/dyn/closer.cgi?action=download&filename=flink/flink-1.16.3/flink-1.16.3-bin-scala_2.12.tgz \
- FLINK_ASC_URL=https://downloads.apache.org/flink/flink-1.16.3/flink-1.16.3-bin-scala_2.12.tgz.asc \
- GPG_KEY=B2D64016B940A7E0B9B72E0D7D0528B28037D8BC \
- CHECK_GPG=true
-
-# Prepare environment
-ENV FLINK_HOME=/opt/flink
-ENV PATH=$FLINK_HOME/bin:$PATH
-RUN groupadd --system --gid=9999 flink && \
- useradd --system --home-dir $FLINK_HOME --uid=9999 --gid=flink flink
-WORKDIR $FLINK_HOME
-
-# Install Flink
-RUN set -ex; \
- wget -nv -O flink.tgz "$FLINK_TGZ_URL"; \
- \
- if [ "$CHECK_GPG" = "true" ]; then \
- wget -nv -O flink.tgz.asc "$FLINK_ASC_URL"; \
- export GNUPGHOME="$(mktemp -d)"; \
- for server in ha.pool.sks-keyservers.net $(shuf -e \
- hkp://p80.pool.sks-keyservers.net:80 \
- keyserver.ubuntu.com \
- hkp://keyserver.ubuntu.com:80 \
- pgp.mit.edu) ; do \
- gpg --batch --keyserver "$server" --recv-keys "$GPG_KEY" && break || : ; \
- done && \
- gpg --batch --verify flink.tgz.asc flink.tgz; \
- gpgconf --kill all; \
- rm -rf "$GNUPGHOME" flink.tgz.asc; \
- fi; \
- \
- tar -xf flink.tgz --strip-components=1; \
- rm flink.tgz; \
- \
- chown -R flink:flink .; \
- \
- # Replace default REST/RPC endpoint bind address to use the container's network interface \
- sed -i 's/rest.address: localhost/rest.address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/rest.bind-address: localhost/rest.bind-address: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/jobmanager.bind-host: localhost/jobmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i 's/taskmanager.bind-host: localhost/taskmanager.bind-host: 0.0.0.0/g' $FLINK_HOME/conf/flink-conf.yaml; \
- sed -i '/taskmanager.host: localhost/d' $FLINK_HOME/conf/flink-conf.yaml;
-
-# Configure container
-COPY docker-entrypoint.sh /
-ENTRYPOINT ["/docker-entrypoint.sh"]
-EXPOSE 6123 8081
-CMD ["help"]
diff --git a/1.16/scala_2.12-java8-ubuntu/docker-entrypoint.sh b/1.16/scala_2.12-java8-ubuntu/docker-entrypoint.sh
deleted file mode 100755
index 8b0350e..0000000
--- a/1.16/scala_2.12-java8-ubuntu/docker-entrypoint.sh
+++ /dev/null
@@ -1,152 +0,0 @@
-#!/usr/bin/env bash
-
-###############################################################################
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-###############################################################################
-
-COMMAND_STANDALONE="standalone-job"
-COMMAND_HISTORY_SERVER="history-server"
-
-# If unspecified, the hostname of the container is taken as the JobManager address
-JOB_MANAGER_RPC_ADDRESS=${JOB_MANAGER_RPC_ADDRESS:-$(hostname -f)}
-CONF_FILE="${FLINK_HOME}/conf/flink-conf.yaml"
-
-drop_privs_cmd() {
- if [ $(id -u) != 0 ]; then
- # Don't need to drop privs if EUID != 0
- return
- elif [ -x /sbin/su-exec ]; then
- # Alpine
- echo su-exec flink
- else
- # Others
- echo gosu flink
- fi
-}
-
-copy_plugins_if_required() {
- if [ -z "$ENABLE_BUILT_IN_PLUGINS" ]; then
- return 0
- fi
-
- echo "Enabling required built-in plugins"
- for target_plugin in $(echo "$ENABLE_BUILT_IN_PLUGINS" | tr ';' ' '); do
- echo "Linking ${target_plugin} to plugin directory"
- plugin_name=${target_plugin%.jar}
-
- mkdir -p "${FLINK_HOME}/plugins/${plugin_name}"
- if [ ! -e "${FLINK_HOME}/opt/${target_plugin}" ]; then
- echo "Plugin ${target_plugin} does not exist. Exiting."
- exit 1
- else
- ln -fs "${FLINK_HOME}/opt/${target_plugin}" "${FLINK_HOME}/plugins/${plugin_name}"
- echo "Successfully enabled ${target_plugin}"
- fi
- done
-}
-
-set_config_option() {
- local option=$1
- local value=$2
-
- # escape periods for usage in regular expressions
- local escaped_option=$(echo ${option} | sed -e "s/\./\\\./g")
-
- # either override an existing entry, or append a new one
- if grep -E "^${escaped_option}:.*" "${CONF_FILE}" > /dev/null; then
- sed -i -e "s/${escaped_option}:.*/$option: $value/g" "${CONF_FILE}"
- else
- echo "${option}: ${value}" >> "${CONF_FILE}"
- fi
-}
-
-prepare_configuration() {
- set_config_option jobmanager.rpc.address ${JOB_MANAGER_RPC_ADDRESS}
- set_config_option blob.server.port 6124
- set_config_option query.server.port 6125
-
- if [ -n "${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}" ]; then
- set_config_option taskmanager.numberOfTaskSlots ${TASK_MANAGER_NUMBER_OF_TASK_SLOTS}
- fi
-
- if [ -n "${FLINK_PROPERTIES}" ]; then
- echo "${FLINK_PROPERTIES}" >> "${CONF_FILE}"
- fi
- envsubst < "${CONF_FILE}" > "${CONF_FILE}.tmp" && mv "${CONF_FILE}.tmp" "${CONF_FILE}"
-}
-
-maybe_enable_jemalloc() {
- if [ "${DISABLE_JEMALLOC:-false}" == "false" ]; then
- JEMALLOC_PATH="/usr/lib/$(uname -m)-linux-gnu/libjemalloc.so"
- JEMALLOC_FALLBACK="/usr/lib/x86_64-linux-gnu/libjemalloc.so"
- if [ -f "$JEMALLOC_PATH" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_PATH
- elif [ -f "$JEMALLOC_FALLBACK" ]; then
- export LD_PRELOAD=$LD_PRELOAD:$JEMALLOC_FALLBACK
- else
- if [ "$JEMALLOC_PATH" = "$JEMALLOC_FALLBACK" ]; then
- MSG_PATH=$JEMALLOC_PATH
- else
- MSG_PATH="$JEMALLOC_PATH and $JEMALLOC_FALLBACK"
- fi
- echo "WARNING: attempted to load jemalloc from $MSG_PATH but the library couldn't be found. glibc will be used instead."
- fi
- fi
-}
-
-maybe_enable_jemalloc
-
-copy_plugins_if_required
-
-prepare_configuration
-
-args=("$@")
-if [ "$1" = "help" ]; then
- printf "Usage: $(basename "$0") (jobmanager|${COMMAND_STANDALONE}|taskmanager|${COMMAND_HISTORY_SERVER})\n"
- printf " Or $(basename "$0") help\n\n"
- printf "By default, Flink image adopts jemalloc as default memory allocator. This behavior can be disabled by setting the 'DISABLE_JEMALLOC' environment variable to 'true'.\n"
- exit 0
-elif [ "$1" = "jobmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/jobmanager.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_STANDALONE} ]; then
- args=("${args[@]:1}")
-
- echo "Starting Job Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/standalone-job.sh" start-foreground "${args[@]}"
-elif [ "$1" = ${COMMAND_HISTORY_SERVER} ]; then
- args=("${args[@]:1}")
-
- echo "Starting History Server"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/historyserver.sh" start-foreground "${args[@]}"
-elif [ "$1" = "taskmanager" ]; then
- args=("${args[@]:1}")
-
- echo "Starting Task Manager"
-
- exec $(drop_privs_cmd) "$FLINK_HOME/bin/taskmanager.sh" start-foreground "${args[@]}"
-fi
-
-args=("${args[@]}")
-
-# Running command in pass-through mode
-exec $(drop_privs_cmd) "${args[@]}"
diff --git a/1.16/scala_2.12-java8-ubuntu/release.metadata b/1.16/scala_2.12-java8-ubuntu/release.metadata
deleted file mode 100644
index 1b48238..0000000
--- a/1.16/scala_2.12-java8-ubuntu/release.metadata
+++ /dev/null
@@ -1,2 +0,0 @@
-Tags: 1.16.3-scala_2.12-java8, 1.16-scala_2.12-java8, scala_2.12-java8, 1.16.3-java8, 1.16-java8, java8
-Architectures: amd64,arm64v8
(flink-docker) 01/02: [FLINK-34282][docker] Updates snapshot workflow to consider the dev-1.19 branch and new dev-master.
Posted by ma...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch FLINK-34282-master
in repository https://gitbox.apache.org/repos/asf/flink-docker.git
commit d448f5432abf46da474404fa57cc92a4cb1ad06e
Author: Matthias Pohl <ma...@aiven.io>
AuthorDate: Fri Feb 9 12:08:21 2024 +0100
[FLINK-34282][docker] Updates snapshot workflow to consider the dev-1.19 branch and new dev-master.
---
.github/workflows/snapshot.yml | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/.github/workflows/snapshot.yml b/.github/workflows/snapshot.yml
index 1d7d53a..3d66cd7 100644
--- a/.github/workflows/snapshot.yml
+++ b/.github/workflows/snapshot.yml
@@ -38,8 +38,10 @@ jobs:
matrix:
java_version: [8, 11]
build:
- - flink_version: 1.19-SNAPSHOT
+ - flink_version: 1.20-SNAPSHOT
branch: dev-master
+ - flink_version: 1.19-SNAPSHOT
+ branch: dev-1.19
- flink_version: 1.18-SNAPSHOT
branch: dev-1.18
- flink_version: 1.17-SNAPSHOT