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

SqlServerConnector crashes with "Received event of unexpected command type: 4"

    XMLWordPrintable

Details

    • Bug
    • Resolution: Cannot Reproduce
    • Major
    • None
    • 0.10.0.Final
    • sqlserver-connector
    • None
    • Hide

      SqlServer 2017.
      Unclear how to reproduce. This is only occurring in one environment, no errors are occurring in other environments that have same setup and similar data.

      Show
      SqlServer 2017. Unclear how to reproduce. This is only occurring in one environment, no errors are occurring in other environments that have same setup and similar data.

    Description

      Connector frequently (several times an hour, but not in any specific pattern) crashes with following error.

      2020-01-30 02:30:38,671 ERROR  ||  WorkerSourceTask{id=db-kafka-connector-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
      org.apache.kafka.connect.errors.ConnectException: An exception ocurred in the change event producer. This connector will be stopped.
              at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:170)
              at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
              at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:161)
              at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:245)
              at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:221)
              at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
              at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
              at java.util.concurrent.FutureTask.run(FutureTask.java:266)
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
              at java.lang.Thread.run(Thread.java:748)
      Caused by: java.lang.IllegalArgumentException: Received event of unexpected command type: 4
              at io.debezium.connector.sqlserver.SqlServerChangeRecordEmitter.getOperation(SqlServerChangeRecordEmitter.java:48)
              at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:39)
              at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:141)
              at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.lambda$execute$1(SqlServerStreamingChangeEventSource.java:228)
              at io.debezium.jdbc.JdbcConnection.prepareQuery(JdbcConnection.java:493)
              at io.debezium.connector.sqlserver.SqlServerConnection.getChangesForTables(SqlServerConnection.java:143)
              at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:151)
              at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:91)
              ... 5 more
      2020-01-30 02:30:38,671 ERROR  ||  WorkerSourceTask{id=db-kafka-connector-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTa
      sk]
      2020-01-30 02:30:38,671 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            nicsnoek Nic Snoek (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: