Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-2345

Error when processing commitLogs related to list-type columns

    XMLWordPrintable

Details

    Description

      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] 

      Attachments

        Activity

          People

            zhou.bing@husky.neu.edu Bingqin Zhou (Inactive)
            zhou.bing@husky.neu.edu Bingqin Zhou (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: