You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@beam.apache.org by Ohad Pinchevsky <oh...@gmail.com> on 2021/09/23 13:48:07 UTC
Apache Beam 2.31 over Flink 1.13 with Java 11 throws RuntimeException
According to the blog in Beam website Java 11 is already supported since
2.27 https://beam.apache.org/blog/beam-2.27.0/
But in the Dockerfile of Beam they have Java 8 installed:
https://hub.docker.com/layers/apache/beam_flink1.13_job_server/2.31.0/images/sha256-e727deacac9b16b5a05066998a8d39e0c2860ced0484246f16566bf384d8b028?context=explore
Flink 1.13 already support Java 11
https://github.com/apache/flink-docker/tree/master/1.13
Running mixed code resulting with exception:
compiled by a more recent version of the Java Runtime (class file version
55.0), this version of the Java Runtime only recognizes class file versions
up to 52.0
Re: Apache Beam 2.31 over Flink 1.13 with Java 11 throws
RuntimeException
Posted by Alexey Romanenko <ar...@gmail.com>.
CC: dev@
> On 23 Sep 2021, at 15:48, Ohad Pinchevsky <oh...@gmail.com> wrote:
> According to the blog in Beam website Java 11 is already supported since 2.27 https://beam.apache.org/blog/beam-2.27.0/ <https://beam.apache.org/blog/beam-2.27.0/>
I believe it’s related only for Java SDK containers whereas Flink (or Spark) job server containers are still built with Java 8.
I think we need fix it.
> But in the Dockerfile of Beam they have Java 8 installed:
>
> https://hub.docker.com/layers/apache/beam_flink1.13_job_server/2.31.0/images/sha256-e727deacac9b16b5a05066998a8d39e0c2860ced0484246f16566bf384d8b028?context=explore <https://hub.docker.com/layers/apache/beam_flink1.13_job_server/2.31.0/images/sha256-e727deacac9b16b5a05066998a8d39e0c2860ced0484246f16566bf384d8b028?context=explore>
>
> Flink 1.13 already support Java 11 https://github.com/apache/flink-docker/tree/master/1.13 <https://github.com/apache/flink-docker/tree/master/1.13>
>
> Running mixed code resulting with exception:
>
> compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0
>
Re: Apache Beam 2.31 over Flink 1.13 with Java 11 throws
RuntimeException
Posted by Alexey Romanenko <ar...@gmail.com>.
CC: dev@
> On 23 Sep 2021, at 15:48, Ohad Pinchevsky <oh...@gmail.com> wrote:
> According to the blog in Beam website Java 11 is already supported since 2.27 https://beam.apache.org/blog/beam-2.27.0/ <https://beam.apache.org/blog/beam-2.27.0/>
I believe it’s related only for Java SDK containers whereas Flink (or Spark) job server containers are still built with Java 8.
I think we need fix it.
> But in the Dockerfile of Beam they have Java 8 installed:
>
> https://hub.docker.com/layers/apache/beam_flink1.13_job_server/2.31.0/images/sha256-e727deacac9b16b5a05066998a8d39e0c2860ced0484246f16566bf384d8b028?context=explore <https://hub.docker.com/layers/apache/beam_flink1.13_job_server/2.31.0/images/sha256-e727deacac9b16b5a05066998a8d39e0c2860ced0484246f16566bf384d8b028?context=explore>
>
> Flink 1.13 already support Java 11 https://github.com/apache/flink-docker/tree/master/1.13 <https://github.com/apache/flink-docker/tree/master/1.13>
>
> Running mixed code resulting with exception:
>
> compiled by a more recent version of the Java Runtime (class file version 55.0), this version of the Java Runtime only recognizes class file versions up to 52.0
>