rakesh-rsky opened a new pull request, #11211: URL: https://github.com/apache/nifi/pull/11211
## Summary Fixes a race condition / NPE in PutKinesisFirehose.onTrigger() where a two-step computeIfAbsent() + get() on the batch-accumulation map could return ull if the entry was evicted between the two calls. ## Changes - Collapsed the two-step lookup into a single atomic computeIfAbsent(...).add(record) call in PutKinesisFirehose.java, eliminating the window for a NullPointerException. ## Testing - Existing unit tests pass. - The fix is a straightforward atomic-operation replacement with no behavioral change under normal conditions. Fixes: https://issues.apache.org/jira/browse/NIFI-14472 -- 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]
