Skip to content

Instantly share code, notes, and snippets.

@gchait
Created December 13, 2025 12:19
Show Gist options
  • Select an option

  • Save gchait/f87c9ba3c85c3c7d318cb0f4cbe81035 to your computer and use it in GitHub Desktop.

Select an option

Save gchait/f87c9ba3c85c3c7d318cb0f4cbe81035 to your computer and use it in GitHub Desktop.
Extend Flink Operator with plugins
FROM ghcr.io/apache/flink-kubernetes-operator:xxxxx
ARG PLUGINS="flink-s3-fs-hadoop flink-s3-fs-presto"
ENV FLINK_PLUGINS_DIR=/opt/flink/plugins
ENV BASE_PLUGIN_JARS_URL=https://repo1.maven.org/maven2/org/apache/flink
RUN cd ${FLINK_PLUGINS_DIR} \
&& flink_version=$(ls ./flink-metrics-prometheus | cut -d"-" -f4 | sed "s/.jar//") \
&& for plugin in ${PLUGINS}; \
do mkdir ${plugin} \
&& wget ${BASE_PLUGIN_JARS_URL}/${plugin}/${flink_version}/${plugin}-${flink_version}.jar -P ${plugin}/; \
done
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment