You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by sa...@apache.org on 2019/06/04 07:15:45 UTC
[atlas] branch master updated: ATLAS-3220 Change hiveDDL name and
qualifiedName
This is an automated email from the ASF dual-hosted git repository.
sarath pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push:
new 2968ad8 ATLAS-3220 Change hiveDDL name and qualifiedName
2968ad8 is described below
commit 2968ad86de1de9e70c9c852ab55935129d38ab40
Author: Le Ma <lm...@cloudera.com>
AuthorDate: Mon May 20 10:25:37 2019 -0700
ATLAS-3220 Change hiveDDL name and qualifiedName
Signed-off-by: Sarath Subramanian <sa...@apache.org>
---
.../main/java/org/apache/atlas/hive/hook/events/BaseHiveEvent.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/BaseHiveEvent.java b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/BaseHiveEvent.java
index b7033ba..c6e764f 100644
--- a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/BaseHiveEvent.java
+++ b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/events/BaseHiveEvent.java
@@ -693,8 +693,9 @@ public abstract class BaseHiveEvent {
hiveDDL.setAttribute(ATTRIBUTE_EXEC_TIME, getQueryStartTime());
hiveDDL.setAttribute(ATTRIBUTE_QUERY_TEXT, getQueryString());
hiveDDL.setAttribute(ATTRIBUTE_USER_NAME, getUserName());
- hiveDDL.setAttribute(ATTRIBUTE_NAME, getQueryString() + QNAME_SEP_PROCESS + getQueryStartTime().toString());
- hiveDDL.setAttribute(ATTRIBUTE_QUALIFIED_NAME, hiveDDL.getAttribute(ATTRIBUTE_NAME));
+ hiveDDL.setAttribute(ATTRIBUTE_NAME, getQueryString());
+ hiveDDL.setAttribute(ATTRIBUTE_QUALIFIED_NAME, dbOrTable.getAttribute(ATTRIBUTE_QUALIFIED_NAME).toString()
+ + QNAME_SEP_PROCESS + getQueryStartTime().toString());
}
return hiveDDL;