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

NullPointerException when receiving noop event

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Critical Critical
    • 0.10.0.Beta1
    • 0.10.0.Alpha2
    • mongodb-connector
    • None

      connect_1             | java.lang.NullPointerException
      connect_1             | 	at io.debezium.connector.mongodb.SourceInfo.database(SourceInfo.java:381)
      connect_1             | 	at io.debezium.connector.AbstractSourceInfoStructMaker.commonStruct(AbstractSourceInfoStructMaker.java:54)
      connect_1             | 	at io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker.struct(MongoDbSourceInfoStructMaker.java:37)
      connect_1             | 	at io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker.struct(MongoDbSourceInfoStructMaker.java:15)
      connect_1             | 	at io.debezium.connector.mongodb.SourceInfo.sourceInfoStructFor(SourceInfo.java:246)
      connect_1             | 	at io.debezium.connector.mongodb.SourceInfo.sourceInfoStructForEvent(SourceInfo.java:229)
      connect_1             | 	at io.debezium.connector.mongodb.Replicator.lambda$recordCurrentOplogPosition$1(Replicator.java:206)
      connect_1             | 	at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:275)
      connect_1             | 	at io.debezium.connector.mongodb.Replicator.recordCurrentOplogPosition(Replicator.java:203)
      connect_1             | 	at io.debezium.connector.mongodb.Replicator.run(Replicator.java:152)
      connect_1             | 	at io.debezium.connector.mongodb.MongoDbConnectorTask.lambda$start$1(MongoDbConnectorTask.java:127)
      connect_1             | 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      connect_1             | 	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
      connect_1             | 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      connect_1             | 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      connect_1             | 	at java.lang.Thread.run(Thread.java:748)
      

      The code assumes there's always be a collection id, but it's not the case when receiving noop events.

              gunnar.morling Gunnar Morling
              gunnar.morling Gunnar Morling
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: