Hi, I'm using flink-kubernetes-repo to deploy some processes. I'm creating a custom DockerFile image with all my python scripts place under /opt/flink/usrlib.
My Job spacification is something like job: jarURI: https://repo1.maven.org/maven2/org/apache/flink/flink-python/1.18.1/flink-python-1.18.1.jar entryClass: "org.apache.flink.client.python.PythonDriver" args: [ "-py", "/opt/flink/usrlib/main.py","--pyFiles", "/opt/flink/usrlib"] parallelism: 1 However, most of the times main.py do not find modules present in /opt/flink/usrlib, although after many retries sometime it does work. It seems that there is a malfunction while submitting the task. Kind regards, [cid:eca05959-7198-49a4-b1af-cf483ad0582a] Aurelio Marin Aranzana Data Scientist nhoa.energy<https://nhoa.energy/> | contact details<https://card.nhoa.energy/aurelio.aranzana> The information contained in this email, including any attachments, constitutes strictly proprietary and confidential material. Its reproduction, distribution, diffusion, transmission to third parties, even partial, directly or indirectly, by any means or form, is prohibited without the prior written authorization of the NHOA Group. All contents of this email constitute confidential proprietary data which will remain the exclusive property of the NHOA Group, which reserves all rights therein. Failure to comply with the above provisions will result in violation of the relevant provisions of the law in any jurisdiction in which the NHOA Group operates.
