----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/73595/#review223547 -----------------------------------------------------------
Why would you not include messageInfo in the message itself? That will make the message self-sufficient and prevent the ctor changes. intg/src/main/java/org/apache/atlas/model/notification/MessageSource.java Lines 54 (patched) <https://reviews.apache.org/r/73595/#comment312611> Refactor: Extract method. Call it: getBuildVersion intg/src/main/java/org/apache/atlas/model/notification/MessageSource.java Lines 80 (patched) <https://reviews.apache.org/r/73595/#comment312612> Since build version will remain the same for a deployment, it will help to store this into a static property. - Ashutosh Mestry On Sept. 29, 2021, 7:30 a.m., chaitali wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/73595/ > ----------------------------------------------------------- > > (Updated Sept. 29, 2021, 7:30 a.m.) > > > Review request for atlas, Ashutosh Mestry, Jayendra Parab, Pinal Shah, and > Sarath Subramanian. > > > Bugs: ATLAS-4428 > https://issues.apache.org/jira/browse/ATLAS-4428 > > > Repository: atlas > > > Description > ------- > > Atlas hook messages doesn't specify the source information of the messages > coming i.e. which hook source - HiveServer2, HiveMetastore, Impala, Spark, > HBase, Kafka. > > Each hook message already captures, the msgSourceIP, msgCreatedBy and > msgCreationTime info. In addition to these, we should capture the msgSource > information as well. > > When messages come from different hook versions, Atlas server should be aware > of the version of different hook messages to process the message based on the > hook version. > > > Diffs > ----- > > > addons/falcon-bridge/src/main/java/org/apache/atlas/falcon/hook/FalconHook.java > 8c09d3394 > > addons/hbase-bridge/src/main/java/org/apache/atlas/hbase/bridge/HBaseAtlasHook.java > 0ab06f2c5 > addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java > 3cc7b3bc6 > > addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveMetastoreHookImpl.java > 6a492c214 > > addons/impala-bridge/src/main/java/org/apache/atlas/impala/hook/ImpalaLineageHook.java > 10ae08f6d > > addons/sqoop-bridge/src/main/java/org/apache/atlas/sqoop/hook/SqoopHook.java > 4785960a7 > > addons/storm-bridge/src/main/java/org/apache/atlas/storm/hook/StormAtlasHook.java > 779c5cb20 > intg/pom.xml 059dddd14 > > intg/src/main/java/org/apache/atlas/model/notification/AtlasNotificationBaseMessage.java > ff45d5713 > > intg/src/main/java/org/apache/atlas/model/notification/AtlasNotificationMessage.java > 5869910cb > intg/src/main/java/org/apache/atlas/model/notification/MessageSource.java > PRE-CREATION > notification/src/main/java/org/apache/atlas/hook/AtlasHook.java 9162ac144 > > notification/src/main/java/org/apache/atlas/notification/AbstractNotification.java > c45a1da95 > > notification/src/main/java/org/apache/atlas/notification/NotificationInterface.java > 3d8d9cc0a > > notification/src/main/java/org/apache/atlas/notification/spool/AtlasFileSpool.java > 0c92c300e > notification/src/test/java/org/apache/atlas/hook/AtlasHookTest.java > 1ae7c278c > > notification/src/test/java/org/apache/atlas/notification/AbstractNotificationTest.java > 8078a6ceb > > notification/src/test/java/org/apache/atlas/notification/entity/EntityNotificationDeserializerTest.java > 13eafb6b1 > > notification/src/test/java/org/apache/atlas/notification/hook/HookNotificationDeserializerTest.java > d04817024 > > > Diff: https://reviews.apache.org/r/73595/diff/3/ > > > Testing > ------- > > mvn clean install > mvn clean package -Pdist,embedded-hbase-solr -DskipTests -Drat.skip > testcases running successfully > > > Thanks, > > chaitali > >
