Repository: atlas Updated Branches: refs/heads/master 2b9aa84d6 -> 618cf3612
ATLAS-2980: fix HBaseBasedAuditRepository.putEventsV2() to store entity-json string Signed-off-by: Madhan Neethiraj <mad...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/618cf361 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/618cf361 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/618cf361 Branch: refs/heads/master Commit: 618cf361201828faba3b7cf1f47dad2e348db634 Parents: 2b9aa84 Author: Sizhong Du <to...@users.noreply.github.com> Authored: Sun Nov 25 16:24:05 2018 -0800 Committer: Madhan Neethiraj <mad...@apache.org> Committed: Sun Nov 25 16:30:59 2018 -0800 ---------------------------------------------------------------------- .../atlas/repository/audit/CassandraBasedAuditRepository.java | 2 +- .../apache/atlas/repository/audit/HBaseBasedAuditRepository.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/618cf361/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 @@ public class CassandraBasedAuditRepository extends AbstractStorageBasedAuditRepo 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); } http://git-wip-us.apache.org/repos/asf/atlas/blob/618cf361/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 @@ public class HBaseBasedAuditRepository extends AbstractStorageBasedAuditReposito addColumn(put, COLUMN_TYPE, ENTITY_AUDIT_V2); if (persistEntityDefinition) { - addColumn(put, COLUMN_DEFINITION, event.getEntity()); + addColumn(put, COLUMN_DEFINITION, event.getEntityDefinitionString()); } puts.add(put);