zhangzhangzhangzy commented on issue #3929:
URL:
https://github.com/apache/incubator-seatunnel/issues/3929#issuecomment-1463170536
java.lang.ClassCastException: cannot assign instance of
io.debezium.relational.TableId to field
org.apache.seatunnel.connectors.cdc.base.source.split.SnapshotSplit.tableId of
type io.debezium.relational.TableId in instance of
org.apache.seatunnel.connectors.cdc.base.source.split.SnapshotSplit
at
java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2301)
~[?:1.8.0_352]
at
java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1431)
~[?:1.8.0_352]
at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2436)
~[?:1.8.0_352]
at
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2354)
~[?:1.8.0_352]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2212)
~[?:1.8.0_352]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668)
~[?:1.8.0_352]
at java.io.ObjectInputStream.readArray(ObjectInputStream.java:2118)
~[?:1.8.0_352]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1656)
~[?:1.8.0_352]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:502)
~[?:1.8.0_352]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:460)
~[?:1.8.0_352]
at
org.apache.seatunnel.common.utils.SerializationUtils.deserialize(SerializationUtils.java:91)
~[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.task.operation.source.AssignSplitOperation.lambda$run$1(AssignSplitOperation.java:57)
~[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:47)
~[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.task.operation.source.AssignSplitOperation.run(AssignSplitOperation.java:54)
~[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:411)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:438)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:601)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:580)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241)
[seatunnel-starter.jar:2.3.0]
at
com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:61)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.utils.NodeEngineUtil.sendOperationToMemberNode(NodeEngineUtil.java:40)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.execution.TaskExecutionContext.sendToMember(TaskExecutionContext.java:43)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.task.context.SeaTunnelSplitEnumeratorContext.assignSplit(SeaTunnelSplitEnumeratorContext.java:55)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.api.source.SourceSplitEnumerator$Context.assignSplit(SourceSplitEnumerator.java:104)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator.assignSplits(IncrementalSourceEnumerator.java:160)
[connector-cdc-mysql-2.3.0.jar:2.3.0]
at
org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator.run(IncrementalSourceEnumerator.java:72)
[connector-cdc-mysql-2.3.0.jar:2.3.0]
at
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:239)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:124)
[seatunnel-starter.jar:2.3.0]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:357)
[seatunnel-starter.jar:2.3.0]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_352]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[?:1.8.0_352]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_352]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_352]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_352]
--
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]
