-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/74344/
-----------------------------------------------------------
Review request for ranger, Dineshkumar Yadav, madhan, Madhan Neethiraj, Ramesh
Mani, and Velmurugan Periasamy.
Bugs: RANGER-4129
https://issues.apache.org/jira/browse/RANGER-4129
Repository: ranger
Description
-------
If AtlasTagSource.buildAndUploadServiceTags() is called with empty
AtlasTagSource.atlasEntityWithTags list, then an ArrayIndexOutOfBounds
exception is thrown when AtlasTagSource.messages list is read. This may happen
when the first notification processed by tagsync process is of type
ENTITY_DELETE.
This Jira also fixes a potential issue if the Kafka queue contains only a large
number of notifications not expected to be handled by tagsync. In such cases,
tagsync will not acknowledge receipt and it may cause back-pressure on Kafka
queue.
Diffs
-----
tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasNotificationMapper.java
a7c456b3d
tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasTagSource.java
1a3ddecb5
Diff: https://reviews.apache.org/r/74344/diff/1/
Testing
-------
Compiled clean and passed all unit tests
Thanks,
Abhay Kulkarni
