Given that the "local://" schema means the jar is available in the
image/container of JobManager, so it could only be supported in the K8s
application mode.
If you configure the jarURI to "file://" schema for session cluster, it
means that this jar file should be available in the
flink-kubernetes-
Hi,
Have a session cluster deployed in kubernetes. Trying to submit a job
following the example given in docs.
When I give
1) spec.job.jarURI:
local:///opt/flink/examples/streaming/StateMachineExample.jar
getting
Error: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException:
Could not fi
