Hi Weihua,
Thanks for your reply!
Even when I use jarURI: "local:///path/to/job.jar" I can see that the
classes loaded by the taskmanager are from something like:
file:/tmp/tm_flink-app-wdqs-taskmanager-1-10/blobStorage/job_94ec61137dc8814f4558116848dd29cc/blob_p-0037843784c2e3ee289c9cc3ec644bc0
Hi, David
The jarURI is required[1], otherwise Flink doesn't know which jar should be
used.
If you are using application mode, you can set jarURI to
"local:///opt/flink/usrlib/your-job.jar", and the jar will not upload to
H/A storage.
Best,
Weihua
On Wed, Apr 5, 2023 at 5:51 PM David Causse w
Hi,
I'm trying to deploy a job (flink 1.16) with the flink-operator, the job
jar is part of the image and placed under /opt/flink/usrlib.
I thought that by placing the job jar there I could avoid setting the
jarURI in the JobSpec but I'm getting a NPE (pasted at the end of this
email) suggesting t
