Apache Flink 1.14.0运行官方Python示例抛出Java版本不支持异常咨询

从你提交的异常栈最底层报错可以直接定位失败原因：Flink 1.14.0的Python API底层依赖Apache Beam组件，你当前使用的Java 14版本不在该Beam版本的支持范围内。Java编写的.jar示例可以正常运行，是因为纯Java Flink作业不会触发Beam组件的Java版本校验逻辑，只有Python API场景才会调用这部分校验逻辑。

• 优先方案：将当前Java版本替换为Flink 1.14官方验证兼容的Java 8或Java 11，替换完成后可执行java -version确认版本生效，重启Flink集群后再运行Python示例即可正常执行
• 临时适配方案：如果不想修改全局Java版本，可以在启动Flink集群、执行Python作业前，先在当前终端执行命令指定JDK路径：

  export JAVA_HOME=/替换为你的JDK8或JDK11的本地安装路径
  

  之后再执行作业命令./bin/flink run --python /Users/[...]/flink-1.14.0/examples/python/datastream/word_count.py即可

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