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

NullPointer Exception on getReplicationSlotInfo for Postgres

    Details

    • Steps to Reproduce:
      Hide

      Not sure

      Show
      Not sure

      Description

      Getting an nullpointerexception:

      java.lang.NullPointerException\n\tat io.debezium.connector.postgresql.connection.PostgresConnection.getReplicationSlotInfo(PostgresConnection.java:141)\n\tat io.debezium.connector.postgresql.PostgresConnectorTask.start(PostgresConnectorTask.java:96)\n\tat io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:49)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:157)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat java.lang.Thread.run(Thread.java:745)\n
      

      The methos `fetchReplicationSlotInfo` return a null value in some cases. So a null value is valid, but calling `.equals` on a null object in the `getReplicationSlotInfo` method will throw the NullPointerException

        Gliffy Diagrams

          Attachments

            Issue Links

              Activity

                People

                • Assignee:
                  jpechanec Jiri Pechanec
                  Reporter:
                  jorkzijlstra Jork Zijlstra
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  2 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: