fengcheche commented on issue #5831:
URL: https://github.com/apache/seatunnel/issues/5831#issuecomment-1826241358
```
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:2133)
~[?:1.8.0_65]
at
java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1305)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2006)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) ~[?:1.8.0_65]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
~[?:1.8.0_65]
at
org.apache.seatunnel.common.utils.SerializationUtils.deserialize(SerializationUtils.java:74)
~[connector-kudu-2.3.3.jar:2.3.3]
at
org.apache.seatunnel.api.serialization.DefaultSerializer.deserialize(DefaultSerializer.java:41)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.api.serialization.DefaultSerializer.deserialize(DefaultSerializer.java:25)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.operation.source.AssignSplitOperation.lambda$run$0(AssignSplitOperation.java:67)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:48)
~[connector-kudu-2.3.3.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.operation.source.AssignSplitOperation.run(AssignSplitOperation.java:54)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)
~[seatunnel-starter.jar:2.3.3]
2023-11-25 15:31:55,706 WARN
org.apache.seatunnel.engine.server.TaskExecutionService - [localhost]:5801
[seatunnel] [5.1] Exception in
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask@6ffc9f2f
java.util.concurrent.CompletionException: 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
com.hazelcast.spi.impl.AbstractInvocationFuture.returnOrThrowWithJoinConventions(AbstractInvocationFuture.java:819)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.AbstractInvocationFuture.resolveAndThrowWithJoinConvention(AbstractInvocationFuture.java:835)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.AbstractInvocationFuture.join(AbstractInvocationFuture.java:553)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.context.SeaTunnelSplitEnumeratorContext.assignSplit(SeaTunnelSplitEnumeratorContext.java:82)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.api.source.SourceSplitEnumerator$Context.assignSplit(SourceSplitEnumerator.java:101)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator.assignSplits(IncrementalSourceEnumerator.java:164)
~[connector-cdc-sqlserver-2.3.3.jar:2.3.3]
at
org.apache.seatunnel.connectors.cdc.base.source.enumerator.IncrementalSourceEnumerator.run(IncrementalSourceEnumerator.java:69)
~[connector-cdc-sqlserver-2.3.3.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.stateProcess(SourceSplitEnumeratorTask.java:303)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.SourceSplitEnumeratorTask.call(SourceSplitEnumeratorTask.java:134)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:613)
~[seatunnel-starter.jar:2.3.3]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_65]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_65]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
~[?:1.8.0_65]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
~[?:1.8.0_65]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_65]
Caused by: 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:2133)
~[?:1.8.0_65]
at
java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1305)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2006)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
~[?:1.8.0_65]
at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) ~[?:1.8.0_65]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
~[?:1.8.0_65]
at
org.apache.seatunnel.common.utils.SerializationUtils.deserialize(SerializationUtils.java:74)
~[connector-kudu-2.3.3.jar:2.3.3]
at
org.apache.seatunnel.api.serialization.DefaultSerializer.deserialize(DefaultSerializer.java:41)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.api.serialization.DefaultSerializer.deserialize(DefaultSerializer.java:25)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.operation.source.AssignSplitOperation.lambda$run$0(AssignSplitOperation.java:67)
~[seatunnel-starter.jar:2.3.3]
at
org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:48)
~[connector-kudu-2.3.3.jar:2.3.3]
at
org.apache.seatunnel.engine.server.task.operation.source.AssignSplitOperation.run(AssignSplitOperation.java:54)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123)
~[seatunnel-starter.jar:2.3.3]
at
com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102)
~[seatunnel-starter.jar:2.3.3]
```
--
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]
