Robert Metzger created FLINK-36073:
--------------------------------------

             Summary: 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


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)

Reply via email to