运行PyFlink官方示例时遇java.base模块权限异常求助

问题原因 #

JDK 9及以上引入的模块系统（JPMS）默认限制了对java.lang包内部字段的反射访问。Flink Python API在序列化/反序列化等操作中可能使用了反射访问String.value字段，而JDK 19默认不允许未命名模块（Flink部分组件运行在该模块下）获取该权限，因此抛出异常。

解决方案 #

方案1：降级到兼容的JDK版本 #

Flink官方推荐使用JDK 8或11（长期支持版本），这两个版本不存在JPMS的严格访问限制。卸载当前JDK 19，安装OpenJDK 11或8即可。

方案2：添加JVM启动参数 #

若坚持使用JDK 19，需修改Flink的JVM配置以开放访问权限：

• 找到Flink安装目录下的conf/flink-conf.yaml文件
• 添加或修改以下配置：

  env.java.opts: "--add-opens java.base/java.lang=ALL-UNNAMED"
  

• 重启Flink集群后重新运行WordCount示例

方案3：升级到兼容JDK 19的Flink版本 #

部分较新的Flink版本（如1.17及以后）已适配JPMS规则，升级到对应版本可解决该问题。

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