[atlas] branch branch-2.0 updated: ATLAS-3915 : impala_process startTime and endTime epoch is being set to 0

[nixon]

This is an automated email from the ASF dual-hosted git repository.

nixon pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/atlas.git


The following commit(s) were added to refs/heads/branch-2.0 by this push:
     new 4be7988  ATLAS-3915 : impala_process startTime and endTime epoch is 
being set to 0
4be7988 is described below

commit 4be79880b6af0e1483b167b7e8f3611beff93d4c
Author: chaitali borole <chaitali.bor...@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>
    (cherry picked from commit 5037871ad95fd1d0a7596307b3f92e471cb84209)
---
 .../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 5e361f7..d840822 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
@@ -529,6 +529,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));
@@ -538,8 +541,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);