xiehanghang opened a new issue, #4117: URL: https://github.com/apache/incubator-seatunnel/issues/4117
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened Seatunnel error deploying flink engine on k8s ``` org.apache.flink.util.FlinkException: Could not load the provided entrypoint class. at org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.getPackagedProgram(ClassPathPackagedProgramRetriever.java:178) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.getPackagedProgram(KubernetesApplicationClusterEntrypoint.java:101) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:71) [flink-dist_2.12-1.13.6.jar:1.13.6] Caused by: org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'org.apache.seatunnel.core.flink.SeatunnelFlink' was not found in the jar file. at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:481) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:153) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:65) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:691) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.getPackagedProgram(ClassPathPackagedProgramRetriever.java:167) ~[flink-dist_2.12-1.13.6.jar:1.13.6] ... 2 more Caused by: java.lang.ClassNotFoundException: org.apache.seatunnel.core.flink.SeatunnelFlink at java.net.URLClassLoader.findClass(URLClassLoader.java:387) ~[?:1.8.0_342] at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_342] at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:64) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:74) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:48) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_342] at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:172) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at java.lang.Class.forName0(Native Method) ~[?:1.8.0_342] at java.lang.Class.forName(Class.java:348) ~[?:1.8.0_342] at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:479) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:153) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:65) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:691) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.getPackagedProgram(ClassPathPackagedProgramRetriever.java:167) ~[flink-dist_2.12-1.13.6.jar:1.13.6] ... 2 more ``` ### SeaTunnel Version 2.3.0 ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "STREAMING" } source { FakeSource { result_table_name = "fake" schema = { fields { name = "string" age = "int" } } } } transform { sql { sql = "select name, age from fake" } } sink { Console { } } ``` ### Running Command ```shell kind: ConfigMap apiVersion: v1 metadata: name: seatunnelflink namespace: mozi-flink annotations: kubesphere.io/creator: xxx data: fake_to_console.conf: >- env { execution.parallelism = 1 job.mode = "STREAMING" } source { FakeSource { result_table_name = "fake" schema = { fields { name = "string" age = "int" } } } } transform { sql { sql = "select name, age from fake" } } sink { Console { } } --- apiVersion: flink.apache.org/v1beta1 kind: FlinkDeployment metadata: name: seatunnel-flink-streaming-example-20 namespace: xxx-flink spec: flinkConfiguration: taskmanager.numberOfTaskSlots: '2' flinkVersion: v1_14 image: 'xxx' job: args: - '--config' - /data/fake_to_console.conf entryClass: org.apache.seatunnel.core.flink.SeatunnelFlink jarURI: 'local:///opt/seatunnel/starter/seatunnel-flink-starter.jar' parallelism: 2 state: running upgradeMode: stateless jobManager: replicas: 1 resource: cpu: 1 memory: 1204M podTemplate: apiVersion: v1 kind: Pod spec: affinity: nodeAffinity: requiredDuringSchedulingIgnoredDuringExecution: nodeSelectorTerms: - matchExpressions: - key: usage operator: In values: - poc containers: - name: flink-main-container volumeMounts: - mountPath: /data name: config-volume tolerations: - effect: NoSchedule key: usage operator: Equal value: poc volumes: - name: config-volume configMap: name: seatunnelflink serviceAccount: flink taskManager: resource: cpu: 1 memory: 1204M ``` ### Error Exception ```log org.apache.flink.util.FlinkException: Could not load the provided entrypoint class. at org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.getPackagedProgram(ClassPathPackagedProgramRetriever.java:178) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.getPackagedProgram(KubernetesApplicationClusterEntrypoint.java:101) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:71) [flink-dist_2.12-1.13.6.jar:1.13.6] Caused by: org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'org.apache.seatunnel.core.flink.SeatunnelFlink' was not found in the jar file. at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:481) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:153) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:65) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:691) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.getPackagedProgram(ClassPathPackagedProgramRetriever.java:167) ~[flink-dist_2.12-1.13.6.jar:1.13.6] ... 2 more Caused by: java.lang.ClassNotFoundException: org.apache.seatunnel.core.flink.SeatunnelFlink at java.net.URLClassLoader.findClass(URLClassLoader.java:387) ~[?:1.8.0_342] at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_342] at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:64) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:74) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:48) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_342] at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:172) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at java.lang.Class.forName0(Native Method) ~[?:1.8.0_342] at java.lang.Class.forName(Class.java:348) ~[?:1.8.0_342] at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:479) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:153) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:65) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:691) ~[flink-dist_2.12-1.13.6.jar:1.13.6] at org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.getPackagedProgram(ClassPathPackagedProgramRetriever.java:167) ~[flink-dist_2.12-1.13.6.jar:1.13.6] ... 2 more ``` ### Flink or Spark Version 1.13 ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
