gitfortian opened a new issue, #6201: URL: https://github.com/apache/seatunnel/issues/6201
### 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 <img width="635" alt="48cd5a8b008a9fdbcb84d833f940e1b" src="https://github.com/apache/seatunnel/assets/52306466/4496a7d7-baf7-4d32-be6c-d4a69d5dbd52";> ### SeaTunnel Version 2.3.4-SNAPSHOT ### SeaTunnel Config ```conf { "env" : { "job.mode" : "BATCH", "job.name" : "SeaTunnel_Job" }, "source" : [ { "split.inverse-sampling.rate" : 1000, "parallelism" : 1, "query" : "SELECT `execute_user`, `execute_date`, `success`, `version` FROM `datasophon`.`migration_history`", "result_table_name" : "Table12235838844736", "split.even-distribution.factor.lower-bound" : 0.05, "plugin_name" : "Jdbc", "url" : "jdbc:mysql://126.124.138.96:3306/dinky?useSSL=false", "password" : "aqqss@123", "driver" : "com.mysql.cj.jdbc.Driver", "split.even-distribution.factor.upper-bound" : 100, "split.sample-sharding.threshold" : 1000, "connection_check_timeout_sec" : 30, "user" : "root", "split.size" : 8096 } ], "transform" : [], "sink" : [ { "batch_size" : 1000, "max_retries" : "3", "schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST", "source_table_name" : "Table12235838844736", "max_commit_attempts" : 3, "auto_commit" : "true", "plugin_name" : "Jdbc", "url" : "jdbc:mysql://192.168.138.96:3306/dinky?useSSL=false", "is_exactly_once" : "false", "database" : "datasophon", "password" : "qqq@123", "transaction_timeout_sec" : -1, "driver" : "com.mysql.cj.jdbc.Driver", "data_save_mode" : "APPEND_DATA", "support_upsert_by_query_primary_key_exist" : "false", "connection_check_timeout_sec" : 30, "multi_table_sink_replica" : 1, "generate_sink_sql" : true, "user" : "root", "table" : "migration_history" } ] } ``` ### Running Command ```shell ST WEB ``` ### Error Exception ```log ava.util.concurrent.CompletionException: comhazelcast.nto serialization HazelcastSerializationException: iava io.Invalidcincompatible: stream classdesc serialVersioassException: ora.apache .seatunnelab1.tablocalclassnUID =-1833990926984508516localclass1045754456194987789at com.hazelcast .spi.AbstractlnvocationFuture.wraplncomplet ionException( AbstractInvocationFuture,iava:1347)atcom.hazelcast.spi..AbstractInvocationFuture.cascadeException( AbstractInvocationFuture,iava: 1340)ataccess$200( AbstractInvocationFuture.iava:65 )com.hazelcast.spi.atcom.hazelcast.spi.ractInvocationFuture.java:1478)impi~actInvocationFuturesApplyNode.execute( Abstat com.hazelcast.spiunblockOtherNode(AbstractInvocationFuture.java:797)atcom.hazelcast .sptonFuture.unblockAll(AbstractInvocationFuture.iava:759atcom.hazelcast.splonFuture,complete0( AbstractInvocationFuture,java: 1235com.hazelcast.spieteExceptionallyInternal(AbstractInvocationFuture,iava:1223)at1mbAbstlionFuturecomblat com.hazelcast.spi.implAbstr actInvocationFuture,completeExceptionally(AbstractInvocationFuture,java:709)at com.hazelcast.client.impl .spi.ClientInvocation.completeExceptionally(ClientInvocation.java:294)moat com.hazelcast.client.impl.spiimpl.ClientInvocation.notifyExceptionWithOwnedPermission(ClientInvocation.java:321)at com.hazelcast.client.impl.spiimpl.ClientInvocation.notifyException(ClientInvocation .java:304)atcom.hazelcast.client.impl.spiimpl.ClientResponseHandlerSupplier handleResponse(ClientResponseHandlerSupplier.iava:164atcom.hazelcastclient .impl .spi.impl.ClientResponseHandlerSupplier .process(ClientResponseHandlerSupplier ,iava:141atcom.hazelcast.clientimpl .spi.1m07CijentResbonsehandlersubolaccess$300lentResponseHandlerSupplier.java: 6(mpl ClientResponseHandlerSuppliersDynamicResponseHandler ,accept(Cl ientResponseHancat comhazelcast.client, impl,spi, mplClientResponseHandlerSuppliersDynamicResponseHandler.accept( ClientResponseHanolerSupplier.java:243)at com.hazelcast.client. impl.connection.tcp .TcpClientConnection.handleclienthlessagelTcpClientConnection,java:245at com.hazelcast.client. impl.protocol.util.ClientMessageDecoder .handleMessage(ClientlessageDecoder.java:135)at.ClientMessageDecoder.onRead( CientMessageDecoder.java:89com.hazelcast.client .impl .protocol .util.atNioInboundPipeline.process(NioInboundPipeline iava: 136com.hazelcast.internal.networking.nioatcom.hazelcast.internal.networkina.processSelectionkey(NioThread.java:383)at com.hazelcast.internal.networkingNioThread.processSelectionKeys(NioThread.iava:368)at com.hazelcast.internal.networking..NioThread.selectLoop(NioThread,iava:294at com.hazelcast.internal.networking.nio.NioThread.executeRun(NioThread,java:249at com.hazelcast. internal.util.executor .HazelcastManagedThread. run(HazelcastManagedthread. java: 102)caused by: com.hazelcast.nioserializat ion.HazelcastSerializationExcept ion: java.io.InvalidClasExcept ion: orgapache.seatunnel.api.table.catalog.PhysicalColumn: local class incompatible: stream clas sdesc serialVersionuD = -1833990926984508516,local class serialVersionUID-1045254456194982289at com.hazelcast.internal serialization.imol .Seralizationlti handleFycention/Serializationllti iava:111atcom.hazelcast.internal ,serializationimpl . Abstractserial.readobiect(AbstractserializationService.iava:355)at com.hazelcast,internalseralization,mol BvteArravobiectDatalnput.readobiectByteArrav0biectDatalnout.iava ``` ### Zeta or Flink or Spark Version _No response_ ### 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]
