You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by ma...@apache.org on 2018/11/26 01:11:43 UTC
atlas git commit: ATLAS-2980: fix
HBaseBasedAuditRepository.putEventsV2() to store entity-json string
Repository: atlas
Updated Branches:
refs/heads/master 2b9aa84d6 -> 618cf3612
ATLAS-2980: fix HBaseBasedAuditRepository.putEventsV2() to store entity-json string
Signed-off-by: Madhan Neethiraj <ma...@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 <ma...@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);