You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@atlas.apache.org by ni...@apache.org on 2020/12/02 08:59:51 UTC
[atlas] branch master updated: ATLAS-3915 : impala_process
startTime and endTime epoch is being set to 0
This is an automated email from the ASF dual-hosted git repository.
nixon 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 5037871 ATLAS-3915 : impala_process startTime and endTime epoch is being set to 0
5037871 is described below
commit 5037871ad95fd1d0a7596307b3f92e471cb84209
Author: chaitali borole <ch...@cloudera.com>
AuthorDate: Tue Aug 11 19:45:16 2020 +0530
ATLAS-3915 : impala_process startTime and endTime epoch is being set to 0
Signed-off-by: nixonrodrigues <ni...@apache.org>
---
.../java/org/apache/atlas/impala/hook/events/BaseImpalaEvent.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/addons/impala-bridge/src/main/java/org/apache/atlas/impala/hook/events/BaseImpalaEvent.java b/addons/impala-bridge/src/main/java/org/apache/atlas/impala/hook/events/BaseImpalaEvent.java
index 5329e8b..32efb83 100644
--- a/addons/impala-bridge/src/main/java/org/apache/atlas/impala/hook/events/BaseImpalaEvent.java
+++ b/addons/impala-bridge/src/main/java/org/apache/atlas/impala/hook/events/BaseImpalaEvent.java
@@ -528,6 +528,9 @@ public abstract class BaseImpalaEvent {
queryStr = queryStr.toLowerCase().trim();
}
+ Long startTime = getQueryStartTime();
+ Long endTime = getQueryEndTime();
+
ret.setAttribute(ATTRIBUTE_QUALIFIED_NAME, getQualifiedName(inputs, outputs));
ret.setAttribute(ATTRIBUTE_INPUTS, getObjectIds(inputs));
ret.setAttribute(ATTRIBUTE_OUTPUTS, getObjectIds(outputs));
@@ -537,8 +540,8 @@ public abstract class BaseImpalaEvent {
// We are setting an empty value to these attributes, since now we have a new entity type called impala process
// execution which captures these values. We have to set empty values here because these attributes are
// mandatory attributes for impala process entity type.
- ret.setAttribute(ATTRIBUTE_START_TIME, EMPTY_ATTRIBUTE_VALUE);
- ret.setAttribute(ATTRIBUTE_END_TIME, EMPTY_ATTRIBUTE_VALUE);
+ ret.setAttribute(ATTRIBUTE_START_TIME, startTime);
+ ret.setAttribute(ATTRIBUTE_END_TIME, endTime);
ret.setAttribute(ATTRIBUTE_USER_NAME, EMPTY_ATTRIBUTE_VALUE);
ret.setAttribute(ATTRIBUTE_QUERY_TEXT, EMPTY_ATTRIBUTE_VALUE);
ret.setAttribute(ATTRIBUTE_QUERY_ID, EMPTY_ATTRIBUTE_VALUE);