Flink 1.18是否支持Java 17?AWS Kinesis作业编译报错求助
问题解答:Flink 1.18与Java 17兼容性及AWS运行时环境问题
这个错误的核心原因是运行你Flink任务的JVM版本是Java 11(对应class文件版本55.0),而你的代码用Java 17(对应class文件版本61.0)编译,高版本JVM编译的字节码无法在低版本JVM上运行,这是JVM的原生兼容性限制,并非Flink 1.18不支持Java 17。
Flink 1.18本身是兼容Java 17的,官方明确支持Java 8、11、17三个版本。问题出在AWS Kinesis Data Analytics(KDA)的Flink 1.18托管运行时——当前AWS提供的该托管环境默认使用Java 11,所以即便你用Java 17编译代码,部署后还是会用Java 11的JVM执行,导致版本不匹配报错。
解决思路:
- 若要继续用Java 17编译代码,需构建自定义Flink运行时镜像:打包包含Java 17和Flink 1.18的镜像上传到ECR,创建KDA集群时选择该自定义镜像。
- 更简便的方式是降级编译目标版本:把代码编译目标设为Java 11(比如Maven项目在pom.xml中配置
<maven.compiler.source>11</maven.compiler.source>和<maven.compiler.target>11</maven.compiler.target>),编译出的字节码可在Java 11环境正常运行,同时代码仍能使用Java 11支持的特性。
内容的提问来源于stack exchange,提问作者sKarwasra
相关产品推荐
相关产品推荐

