Repository: atlas Updated Branches: refs/heads/branch-1.0 379dc7475 -> d88771e10
ATLAS-2980: fix HBaseBasedAuditRepository.putEventsV2() to store entity-json string Signed-off-by: Madhan Neethiraj <mad...@apache.org> (cherry picked from commit 618cf361201828faba3b7cf1f47dad2e348db634) Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/d88771e1 Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/d88771e1 Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/d88771e1 Branch: refs/heads/branch-1.0 Commit: d88771e10a95654c896b837dddb2bdc1a9ac5cee Parents: 379dc74 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 17:12:04 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/d88771e1/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/d88771e1/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);
