Hey we are trying to submit Python Job usiing Kubernetive Flink Operator in Session Cluster
But the jobs is failing since it is showing not a valid directory event the directory path is correct as per the image
/opt/flink/opt/flink-python-1.17.1.jar
Can someone please help out here
My Job file looks like
apiVersion:
flink.apache.org/v1beta1
kind: FlinkSessionJob
metadata:
name: flink-finance-job
spec:
deploymentName: flink-session-cluster
job:
jarURI: /opt/flink/opt/flink-python-1.17.1.jar # Note, this jarURI is actually a placeholder
entryClass: “org.apache.flink.client.python.PythonDriver”
args: [“-pyclientexec”, “/usr/local/bin/python3”, “-py”, “/opt/flink/usrlib/python_demo.py”]
parallelism: 8
upgradeMode: stateless