sandyustc opened a new issue, #7861: URL: https://github.com/apache/seatunnel/issues/7861
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened 2024-10-16 19:13:05,538 INFO org.apache.seatunnel.engine.server.CoordinatorService - [202.120.11.163]:5801 [seatunnel] [5.1] Received task end from execution TaskGroupLocation{jobId=898890920363950093, pipelineId=1, taskGroupId=1}, state CANCELED 2024-10-16 19:13:05,539 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job RouteJobName (898890920363950093), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (5/20)] turn to end state FAILED. 2024-10-16 19:13:05,539 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job RouteJobName (898890920363950093), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (5/20)] end with state **FAILED and Exception: com.hazelcast.nio.serialization.HazelcastSerializationException: java.lang.ClassNotFoundException: com.xxx.plm.wtpartmaster.data.porcess.WtpartmasterRouteProcessSink** at com.hazelcast.internal.serialization.impl.defaultserializers.JavaDefaultSerializers$JavaSerializer.read(JavaDefaultSerializers.java:96) at com.hazelcast.internal.serialization.impl.defaultserializers.JavaDefaultSerializers$JavaSerializer.read(JavaDefaultSerializers.java:85) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:44) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toObject(AbstractSerializationService.java:268) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.deserializeWithCustomClassLoader(CustomClassLoadedObject.java:66) at org.apache.seatunnel.engine.server.TaskExecutionService.deployTask(TaskExecutionService.java:260) at org.apache.seatunnel.engine.server.TaskExecutionService.deployTask(TaskExecutionService.java:239) at org.apache.seatunnel.engine.server.task.operation.DeployTaskOperation.run(DeployTaskOperation.java:56) at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:471) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:197) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:137) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) Caused by: java.lang.ClassNotFoundException: com.xxx.plm.wtpartmaster.data.porcess.WtpartmasterRouteProcessSink at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:440) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:587) at org.apache.seatunnel.engine.common.loader.SeaTunnelBaseClassLoader.loadClassWithoutExceptionHandling(SeaTunnelBaseClassLoader.java:56) at org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader.loadClassWithoutExceptionHandling(SeaTunnelChildFirstClassLoader.java:95) at org.apache.seatunnel.engine.common.loader.SeaTunnelBaseClassLoader.loadClass(SeaTunnelBaseClassLoader.java:47) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520) at com.hazelcast.internal.nio.ClassLoaderUtil.tryLoadClass(ClassLoaderUtil.java:301) at com.hazelcast.internal.nio.ClassLoaderUtil.loadClass(ClassLoaderUtil.java:259) at com.hazelcast.internal.nio.IOUtil$ClassLoaderAwareObjectInputStream.resolveClass(IOUtil.java:867) at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2043) at java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1907) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2209) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472) at java.base/java.util.ArrayList.readObject(ArrayList.java:899) at java.base/jdk.internal.reflect.GeneratedMethodAccessor21.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at java.base/java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1231) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2408) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472) at java.base/java.util.HashMap.readObject(HashMap.java:1546) at java.base/jdk.internal.reflect.GeneratedMethodAccessor25.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at java.base/java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1231) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2408) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472) at com.hazelcast.internal.serialization.impl.defaultserializers.JavaDefaultSerializers$JavaSerializer.read(JavaDefaultSerializers.java:92) ... 15 more ### SeaTunnel Version 2.3.3 ### SeaTunnel Config ```conf { "env": { "parallelism": 1, "job.mode": "batch", "checkpoint.interval": 10000 }, "source": [{ "plugin_name": "jdbc", "url": "jdbc:oracle:thin:@xxx.xxx.11.xxx:1521:orcl", "driver": "oracle.jdbc.OracleDriver", "connection_check_timeout_sec": 100, "user": "xxxg", "password": "xxxg", "query": "select * from user3", "partition_column": "ID", "split.size": 10000 }], "transform": [ ], "sink": [{ "plugin_name": "ownnerplugin", "url": "jdbc:postgresql://xxx.xxx.11.xxx:5432/xxxx", "driver": "org.postgresql.Driver", "user": "pixg", "password": "erdc", "generate_sink_sql": true, "database": xxsk "table": "public.user5", "schema_save_mode": "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode": "APPEND_DATA", "primary_keys": ["ID"] }] } ``` ### Running Command ```shell /hazelcast/rest/maps/submit-job ``` ### Error Exception ```log 2024-10-16 19:13:05,538 INFO org.apache.seatunnel.engine.server.CoordinatorService - [202.120.11.163]:5801 [seatunnel] [5.1] Received task end from execution TaskGroupLocation{jobId=898890920363950093, pipelineId=1, taskGroupId=1}, state CANCELED 2024-10-16 19:13:05,539 INFO org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job RouteJobName (898890920363950093), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (5/20)] turn to end state FAILED. 2024-10-16 19:13:05,539 ERROR org.apache.seatunnel.engine.server.dag.physical.PhysicalVertex - Job RouteJobName (898890920363950093), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Jdbc-default-identifier]-SourceTask (5/20)] end with state FAILED and Exception: com.hazelcast.nio.serialization.HazelcastSerializationException: java.lang.ClassNotFoundException: com.xxx.plm.wtpartmaster.data.porcess.WtpartmasterRouteProcessSink at com.hazelcast.internal.serialization.impl.defaultserializers.JavaDefaultSerializers$JavaSerializer.read(JavaDefaultSerializers.java:96) at com.hazelcast.internal.serialization.impl.defaultserializers.JavaDefaultSerializers$JavaSerializer.read(JavaDefaultSerializers.java:85) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:44) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toObject(AbstractSerializationService.java:268) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.deserializeWithCustomClassLoader(CustomClassLoadedObject.java:66) at org.apache.seatunnel.engine.server.TaskExecutionService.deployTask(TaskExecutionService.java:260) at org.apache.seatunnel.engine.server.TaskExecutionService.deployTask(TaskExecutionService.java:239) at org.apache.seatunnel.engine.server.task.operation.DeployTaskOperation.run(DeployTaskOperation.java:56) at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:471) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:197) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:137) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) Caused by: java.lang.ClassNotFoundException: com.xxx.plm.wtpartmaster.data.porcess.WtpartmasterRouteProcessSink at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:440) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:587) at org.apache.seatunnel.engine.common.loader.SeaTunnelBaseClassLoader.loadClassWithoutExceptionHandling(SeaTunnelBaseClassLoader.java:56) at org.apache.seatunnel.engine.common.loader.SeaTunnelChildFirstClassLoader.loadClassWithoutExceptionHandling(SeaTunnelChildFirstClassLoader.java:95) at org.apache.seatunnel.engine.common.loader.SeaTunnelBaseClassLoader.loadClass(SeaTunnelBaseClassLoader.java:47) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520) at com.hazelcast.internal.nio.ClassLoaderUtil.tryLoadClass(ClassLoaderUtil.java:301) at com.hazelcast.internal.nio.ClassLoaderUtil.loadClass(ClassLoaderUtil.java:259) at com.hazelcast.internal.nio.IOUtil$ClassLoaderAwareObjectInputStream.resolveClass(IOUtil.java:867) at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2043) at java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1907) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2209) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472) at java.base/java.util.ArrayList.readObject(ArrayList.java:899) at java.base/jdk.internal.reflect.GeneratedMethodAccessor21.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at java.base/java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1231) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2408) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472) at java.base/java.util.HashMap.readObject(HashMap.java:1546) at java.base/jdk.internal.reflect.GeneratedMethodAccessor25.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at java.base/java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1231) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2408) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream$FieldValues.<init>(ObjectInputStream.java:2584) at java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2442) at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2242) at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1742) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514) at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472) at com.hazelcast.internal.serialization.impl.defaultserializers.JavaDefaultSerializers$JavaSerializer.read(JavaDefaultSerializers.java:92) ... 15 more ``` ### Zeta or Flink or Spark Version zeta ### Java or Scala Version 1.8 ### 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]
