m1a2st opened a new pull request, #21717: URL: https://github.com/apache/kafka/pull/21717
The PR fixed an NPE when connectorStatusMetrics unregistering task. The issue will happen if a connector has more than 1 task on one worker and these tasks fail to start. For example, if the DNS cant resolve producer URL, tasks will fail to build. If these tasks failing to start, ConnectorStatusMetricsGroup will unregister them. After first task unregistered , connectorStatusMetrics removed connector. When second task calls `recordTaskRemoved()`, connectorStatusMetrics is empty, so `connectorStatusMetrics.get(connectorTaskId.connector()).close();` will throw NPE. Like in method `recordTaskAdded()`, this fix checks connectorStatusMetrics at the beginning of method `recordTaskRemoved()`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
