Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-370

Fix resource management in MongoSourceTask, MongoSinkTask

    • Type: Icon: Bug Bug
    • Resolution: Fixed
    • Priority: Icon: Critical - P2 Critical - P2
    • 1.10.1
    • Affects Version/s: 1.9.0
    • Component/s: Source
    • None
    • Needed
    • Hide

      We need to mention in What's new that we fixed a bug that caused resource leak if source/sink tasks fail to start.

      Show
      We need to mention in What's new that we fixed a bug that caused resource leak if source/sink tasks fail to start.

      Refactoring I did in the source connector 1.9.0 introduced a resource leak: if MongoSourceTask.start fails, then neither StatisticsManager, nor MongoCopyDataManager, nor, most importantly, MongoClient get closed. Not only this causes the leak on the connector-side, but also on the server-side, as MongoClient keeps maintaining/re-creating monitoring connections (at the very least) with the server.

            Assignee:
            valentin.kovalenko@mongodb.com Valentin Kavalenka
            Reporter:
            valentin.kovalenko@mongodb.com Valentin Kavalenka
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: