[
https://issues.apache.org/jira/browse/BEAM-12944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17476334#comment-17476334
]
Kenneth Knowles commented on BEAM-12944:
----------------------------------------
Ah, yes. Pinging [~ibzib] and [~kileys] about this. They know the most about
the Flink runner and job server and Java versions in various containers.
Ideally we don't have to have different versions of the Flink job server, but
it can accept a Beam job for different Java versions and use the
{{beam_java8_sdk}} or {{beam_java11_sdk}} containers for running DoFns. Is this
perhaps due to using {{EMBEDDED}} mode?
> Apache Beam 2.31 over Flink 1.13 with Java 11 throw RuntimeException
> --------------------------------------------------------------------
>
> Key: BEAM-12944
> URL: https://issues.apache.org/jira/browse/BEAM-12944
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Affects Versions: 2.31.0, 2.32.0
> Reporter: Ohad Pinchevsky
> Priority: P2
>
> Docker image contains Java 8 compiled classes
> [https://hub.docker.com/layers/apache/beam_flink1.13_job_server/latest/images/sha256-2a41a876d966196a8a82fe6a555a408310098a8c776d208c916f4f52bd9e4fd4?context=explore]
> I'm unable to use Java 11 code although flink 1.13 has support for Java 11
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
