Repository: incubator-atlas Updated Branches: refs/heads/master ea6c3cb5a -> f6388234b
Remove QueryPlan attribute from Hive Process entity Project: http://git-wip-us.apache.org/repos/asf/incubator-atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-atlas/commit/f6388234 Tree: http://git-wip-us.apache.org/repos/asf/incubator-atlas/tree/f6388234 Diff: http://git-wip-us.apache.org/repos/asf/incubator-atlas/diff/f6388234 Branch: refs/heads/master Commit: f6388234b8f1fac00e83df08614c346957107573 Parents: ea6c3cb Author: Vimal Sharma <[email protected]> Authored: Mon Nov 14 14:03:01 2016 +0530 Committer: Vimal Sharma <[email protected]> Committed: Mon Nov 14 14:03:01 2016 +0530 ---------------------------------------------------------------------- .../org/apache/atlas/hive/hook/HiveHook.java | 23 +------------------- release-log.txt | 1 + 2 files changed, 2 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/f6388234/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java ---------------------------------------------------------------------- diff --git a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java index 0c6582b..cc83c08 100755 --- a/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java +++ b/addons/hive-bridge/src/main/java/org/apache/atlas/hive/hook/HiveHook.java @@ -175,7 +175,6 @@ public class HiveHook extends AtlasHook implements ExecuteWithHookContext { final HiveEventContext event = new HiveEventContext(); event.setInputs(hookContext.getInputs()); event.setOutputs(hookContext.getOutputs()); - event.setJsonPlan(getQueryPlan(hookContext.getConf(), hookContext.getQueryPlan())); event.setHookType(hookContext.getHookType()); event.setUgi(hookContext.getUgi()); event.setUser(getUser(hookContext.getUserName())); @@ -668,18 +667,6 @@ public class HiveHook extends AtlasHook implements ExecuteWithHookContext { } } - private JSONObject getQueryPlan(HiveConf hiveConf, QueryPlan queryPlan) throws Exception { - try { - ExplainTask explain = new ExplainTask(); - explain.initialize(hiveConf, queryPlan, null); - List<Task<?>> rootTasks = queryPlan.getRootTasks(); - return explain.getJSONPlan(null, null, rootTasks, queryPlan.getFetchTask(), true, false, false); - } catch (Throwable e) { - LOG.info("Failed to get queryplan", e); - return new JSONObject(); - } - } - private boolean isSelectQuery(HiveEventContext event) { if (event.getOperation() == HiveOperation.QUERY) { //Select query has only one output @@ -778,7 +765,7 @@ public class HiveHook extends AtlasHook implements ExecuteWithHookContext { processReferenceable.set("userName", hiveEvent.getUser()); processReferenceable.set("queryText", queryStr); processReferenceable.set("queryId", hiveEvent.getQueryId()); - processReferenceable.set("queryPlan", hiveEvent.getJsonPlan()); + processReferenceable.set("queryPlan", "Not Supported"); processReferenceable.set(AtlasConstants.CLUSTER_NAME_ATTRIBUTE, dgiBridge.getClusterName()); List<String> recentQueries = new ArrayList<>(1); @@ -1022,10 +1009,6 @@ public class HiveHook extends AtlasHook implements ExecuteWithHookContext { this.hookType = hookType; } - public void setJsonPlan(JSONObject jsonPlan) { - this.jsonPlan = jsonPlan; - } - public void setQueryId(String queryId) { this.queryId = queryId; } @@ -1075,10 +1058,6 @@ public class HiveHook extends AtlasHook implements ExecuteWithHookContext { return hookType; } - public JSONObject getJsonPlan() { - return jsonPlan; - } - public String getQueryId() { return queryId; } http://git-wip-us.apache.org/repos/asf/incubator-atlas/blob/f6388234/release-log.txt ---------------------------------------------------------------------- diff --git a/release-log.txt b/release-log.txt index acc5734..dc9c36f 100644 --- a/release-log.txt +++ b/release-log.txt @@ -9,6 +9,7 @@ ATLAS-1060 Add composite indexes for exact match performance improvements for al ATLAS-1127 Modify creation and modification timestamps to Date instead of Long(sumasai) ALL CHANGES: +ATLAS-1279 Remove QueryPlan attribute from Hive Process entity (svimal2106) ATLAS-1234 Lineage REST API - v2 ([email protected] via mneethiraj) ATLAS-1276 fix for webapp test failures (ayubkhan via mneethiraj) ATLAS-1278 Added API to get typedef header info (apoorvnaik via mneethiraj)
