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

Stop and Start a connect task is giving error .

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Major Major
    • None
    • None
    • mysql-connector

      I had checked with Gunnar and Jiri. As Jiri suggested , he asked to log a jira to track the issue.

      We are running debezium mysql connector in a two node machine. If we start and stop in very next time it works. If we stop
      the connector after 1day of start And then we try to start it . It throws below error.
      Debezium version: 0.8.1

      [2019-01-24 10:28:15,522] ERROR WorkerSourceTask

      {id=mysql-connector-de-0}

      Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:177)
      org.apache.kafka.connect.errors.ConnectException: java.lang.IllegalStateException: The database history couldn't be recovered. Consider to increase the value for database.history.kafka.recovery.poll.interval.ms
      at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:218)
      at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:45)
      at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:198)
      at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
      at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
      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.IllegalStateException: The database history couldn't be recovered. Consider to increase the value for database.history.kafka.recovery.poll.interval.ms
      at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:215)
      at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:73)
      at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:245)
      at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:163)
      at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:95)

              Unassigned Unassigned
              durgaprasad19 Durga Prasad (Inactive)
              Votes:
              1 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated: