-
Bug
-
Resolution: Done
-
Major
-
None
-
None
Encountered error when processing commitLogs related to list type columns:
16:18:25.849 [pool-4-thread-4] ERROR i.d.c.c.CassandraConnectorTask - Encountered exception while running Commit Log Processor; stopping all processors in Cassandra Connector Task java.lang.ClassCastException: org.apache.cassandra.db.rows.ComplexColumnData cannot be cast to org.apache.cassandra.db.rows.Cell at org.apache.cassandra.db.rows.BTreeRow.getCell(BTreeRow.java:224) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CommitLogReadHandlerImpl.populateRegularColumns(CommitLogReadHandlerImpl.java:422) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CommitLogReadHandlerImpl.handleRowModifications(CommitLogReadHandlerImpl.java:368) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CommitLogReadHandlerImpl.process(CommitLogReadHandlerImpl.java:284) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CommitLogReadHandlerImpl.handleMutation(CommitLogReadHandlerImpl.java:232) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at org.apache.cassandra.db.commitlog.CommitLogReader.readMutation(CommitLogReader.java:485) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at org.apache.cassandra.db.commitlog.CommitLogReader.readSection(CommitLogReader.java:404) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at org.apache.cassandra.db.commitlog.CommitLogReader.readCommitLogSegment(CommitLogReader.java:251) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at org.apache.cassandra.db.commitlog.CommitLogReader.readCommitLogSegment(CommitLogReader.java:141) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CommitLogProcessor.processCommitLog(CommitLogProcessor.java:112) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CommitLogProcessor.process(CommitLogProcessor.java:92) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.AbstractProcessor.start(AbstractProcessor.java:61) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at io.debezium.connector.cassandra.CassandraConnectorTask$ProcessorGroup.lambda$start$0(CassandraConnectorTask.java:200) ~[debezium-connector-cassandra-1.2.0.Final-jar-with-dependencies.jar:1.2.0.Final] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[na:1.8.0_231] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_231] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[na:1.8.0_231] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[na:1.8.0_231] at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_231]