commit 618cf361201828faba3b7cf1f47dad2e348db634
author Sizhong Du <TomDu@users.noreply.github.com> Sun Nov 25 16:24:05 2018 -0800
committer Madhan Neethiraj <madhan@apache.org> Sun Nov 25 16:30:59 2018 -0800
tree ad8002789844f7ed6f6d3963bd0ede190e56e575
parent 2b9aa84d627ffec63a36ba345244703a8f4d557a

ATLAS-2980: fix HBaseBasedAuditRepository.putEventsV2() to store entity-json string

Signed-off-by: Madhan Neethiraj <madhan@apache.org>

repository/src/main/java/org/apache/atlas/repository/audit/CassandraBasedAuditRepository.java

diff --git a/repository/src/main/java/org/apache/atlas/repository/audit/CassandraBasedAuditRepository.java b/repository/src/main/java/org/apache/atlas/repository/audit/CassandraBasedAuditRepository.java
index 8b185a3..eb78f8f 100644
--- a/repository/src/main/java/org/apache/atlas/repository/audit/CassandraBasedAuditRepository.java
+++ b/repository/src/main/java/org/apache/atlas/repository/audit/CassandraBasedAuditRepository.java
@@ -117,7 +117,7 @@
     BatchStatement batch = new BatchStatement();
     events.forEach(event -> batch.add(stmt.bind(event.getEntityId(), event.getTimestamp(),
         event.getAction().toString(), event.getUser(), event.getDetails(),
-        (persistEntityDefinition ? event.getEntity().toString() : null))));
+        (persistEntityDefinition ? event.getEntityDefinitionString() : null))));
     cassSession.execute(batch);
   }
 

repository/src/main/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepository.java

diff --git a/repository/src/main/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepository.java b/repository/src/main/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepository.java
index d0ff229..6f4415f 100644
--- a/repository/src/main/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepository.java
+++ b/repository/src/main/java/org/apache/atlas/repository/audit/HBaseBasedAuditRepository.java
@@ -189,7 +189,7 @@
                 addColumn(put, COLUMN_TYPE, ENTITY_AUDIT_V2);
 
                 if (persistEntityDefinition) {
-                    addColumn(put, COLUMN_DEFINITION, event.getEntity());
+                    addColumn(put, COLUMN_DEFINITION, event.getEntityDefinitionString());
                 }
 
                 puts.add(put);