Commit 2968ad86 by Le Ma Committed by Sarath Subramanian

ATLAS-3220 Change hiveDDL name and qualifiedName

parent af25456d
......@@ -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;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment