如何在Apache Flink Kubernetes Operator中覆盖Docker入口点？

问题原因 #

Flink Kubernetes Operator的核心设计逻辑是强制控制容器的启动命令，它会自动为flink-main-container设置command: ["/docker-entrypoint.sh"]，这个配置会直接覆盖镜像中定义的ENTRYPOINT；同时Operator会根据组件类型（JobManager/TaskManager）传递对应的启动参数，所以直接修改Dockerfile的ENTRYPOINT或在podTemplate中设置command都会被Operator覆盖。

解决方案 #

下面提供两种可行的解决思路：

方案1：修改官方Entrypoint，注入自定义脚本

直接修改官方的/opt/flink/docker-entrypoint.sh，在其执行流程最前端加入自定义脚本调用，这样Operator启动的官方entrypoint会自动先执行你的逻辑：

1. 调整Dockerfile：

FROM flink:1.14.2-scala_2.12-java11

ENV FLINK_HOME=/opt/flink

# 复制自定义脚本到Flink的bin目录
COPY custom-docker-entrypoint.sh /opt/flink/bin/
RUN chmod a+x /opt/flink/bin/custom-docker-entrypoint.sh

# 修改官方entrypoint，在开头插入自定义脚本调用
RUN sed -i '1i /opt/flink/bin/custom-docker-entrypoint.sh' /opt/flink/docker-entrypoint.sh

# 复制你的Flink应用Jar包
COPY --chown=flink:flink --from=build /target/*.jar /opt/flink/flink-web-upload/

EXPOSE 6123 8081

2. 编写custom-docker-entrypoint.sh的自定义逻辑（比如初始化配置、环境变量等）：

#!/bin/bash
set -e

# 这里添加你的自定义前置逻辑
echo "执行自定义启动前操作..."
# 示例：设置自定义环境变量
export MY_CUSTOM_VAR="foo"

# 脚本执行完后会自动回到官方entrypoint的流程

方案2：使用自定义Entrypoint接管启动流程，保留Flink官方逻辑

如果希望完全使用自己的entrypoint脚本，可以在podTemplate中显式设置command为你的脚本，同时让脚本接收Operator传递的启动参数并转发给官方entrypoint：

1. 保持你的Dockerfile不变（保留自定义ENTRYPOINT的配置）：

FROM flink:1.14.2-scala_2.12-java11

ENV FLINK_HOME=/opt/flink

COPY custom-docker-entrypoint.sh /
RUN chmod a+x /custom-docker-entrypoint.sh
COPY --chown=flink:flink --from=build /target/*.jar /opt/flink/flink-web-upload/

ENTRYPOINT ["/custom-docker-entrypoint.sh"]
EXPOSE 6123 8081
CMD ["help"]

2. 修改custom-docker-entrypoint.sh，确保它能接收并转发Operator的启动参数给官方entrypoint：

#!/bin/bash
set -e

# 自定义启动逻辑
echo "执行自定义启动逻辑..."

# 调用官方entrypoint并传递所有参数（Operator会传入jobmanager/taskmanager等参数）
exec /opt/flink/docker-entrypoint.sh "$@"

3. 在FlinkDeployment的podTemplate中显式设置command为你的脚本（覆盖Operator的默认command）：

apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
  name: flink-example
  namespace: default
spec:
  flinkVersion: v1_14
  image: "flink-example:0.1.0"
  podTemplate:
    apiVersion: v1
    kind: Pod
    metadata:
      name: pod-template
    spec:
      containers:
        - name: flink-main-container
          command: ["/custom-docker-entrypoint.sh"]

注意事项 #

• 确保自定义脚本拥有可执行权限（chmod a+x），并且以exec方式调用官方entrypoint，避免产生额外的子进程，保证信号能正确传递给Flink进程。
• 如果你需要在脚本中使用Flink的环境变量，确保脚本开头加上set -e以保证错误能被捕获，同时继承容器的环境变量。

内容的提问来源于stack exchange，提问作者Kubus