You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ferenc Csaky (Jira)" <ji...@apache.org> on 2024/08/15 20:42:00 UTC
[jira] [Commented] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins
[ https://issues.apache.org/jira/browse/FLINK-36073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874056#comment-17874056 ]
Ferenc Csaky commented on FLINK-36073:
--------------------------------------
I will be able to spend some time on this in the next couple days.
> ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins
> ----------------------------------------------------------------------------------------------
>
> Key: FLINK-36073
> URL: https://issues.apache.org/jira/browse/FLINK-36073
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 2.0.0, 1.19.2, 1.20.1
> Reporter: Robert Metzger
> Assignee: Ferenc Csaky
> Priority: Major
>
> As discussed in this ticket https://issues.apache.org/jira/browse/FLINK-28915 we can not define a FlinkDeployment spec with
> {code}
> spec:
> job:
> jarURI: s3://myDevBucket/myjob.jar
> {code}
> It fails with:
> {code}
> org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.main(StandaloneApplicationClusterEntryPoint.java:89) [flink-dist-1.19-x.jar:1.19-x]
> Caused by: java.net.MalformedURLException: unknown protocol: s3
> at java.net.URL.<init>(URL.java:652) ~[?:?]
> at java.net.URL.<init>(URL.java:541) ~[?:?]
> at java.net.URL.<init>(URL.java:488) ~[?:?]
> at org.apache.flink.configuration.ConfigUtils.decodeListFromConfig(ConfigUtils.java:133) ~[flink-dist-1.19-x.jar:1.19-x]
> at org.apache.flink.client.program.DefaultPackagedProgramRetriever.getClasspathsFromConfiguration(DefaultPackagedProgramRetriever.java:273) ~[flink-dist-1.19-x.jar:1.19-x]
> at org.apache.flink.client.program.DefaultPackagedProgramRetriever.create(DefaultPackagedProgramRetriever.java:121) ~[flink-dist-1.19-x.jar:1.19-x]
> ... 4 more
> {code}
> even though I have defined:
> {code}
> podTemplate:
> spec:
> containers:
> - name: flink-main-container
> env:
> - name: ENABLE_BUILT_IN_PLUGINS
> value: "flink-s3-fs-presto-1.19.0.jar"
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)