运行Apache Flink SocketWindowWordCount程序时遇非法反射访问警告

我来帮你梳理这个问题：你看到的这些警告是Flink 1.10版本和Java 9+模块化系统（JPMS）之间的兼容性小问题——具体是Flink的org.apache.flink.api.java.ClosureCleaner类在处理闭包逻辑时，通过反射访问了java.lang.String的私有value字段，而Java 9之后对这种跨模块的非法反射访问做了限制，所以抛出了这些提示。

不过先放宽心，你的作业已经成功提交了（JobID: a4badaa76080e47e82a322a4e2060e45），核心功能不会受影响。下面给你几个处理方案：

• 直接忽略（最简单）：这个警告只是Java给出的前瞻性提示，告诉你未来版本会彻底禁止这种操作，但当前版本下作业运行完全正常。如果没有其他异常，完全可以不用管它。
• 升级Flink版本（彻底解决）：Flink在1.11及以后的版本中已经修复了这个反射访问的问题，升级到较新的稳定版本（比如1.15、1.16这类LTS版本）就能彻底消除这类警告，同时还能获得更多功能和bug修复。
• 添加JVM参数临时规避：如果暂时没法升级，可以在Flink的配置里添加JVM参数来允许这种访问。找到Flink安装目录下的conf/flink-conf.yaml，添加或修改以下配置：

  env.java.opts: --illegal-access=permit
  

  注意：这个参数在Java 16及以上版本已经失效，因为Java 16开始默认完全禁止非法反射访问，这种情况下还是升级Flink版本更靠谱。

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