You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sp...@apache.org on 2015/05/20 18:01:51 UTC

[32/50] [abbrv] hive git commit: HIVE-9974: Sensitive data redaction: data appears in name of mapreduce job (Sergio Pena, reviewed by Xuefu Zhang)

HIVE-9974: Sensitive data redaction: data appears in name of mapreduce job (Sergio Pena, reviewed by Xuefu Zhang)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/65d04bc2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/65d04bc2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/65d04bc2

Branch: refs/heads/parquet
Commit: 65d04bc22838c4bd7a1a95d21d7d1a1a1eb85ebf
Parents: 037559f
Author: Sergio Pena <se...@cloudera.com>
Authored: Mon May 18 13:06:03 2015 -0500
Committer: Sergio Pena <se...@cloudera.com>
Committed: Mon May 18 13:06:03 2015 -0500

----------------------------------------------------------------------
 ql/src/java/org/apache/hadoop/hive/ql/Driver.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/65d04bc2/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
index 338e755..f046c65 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java
@@ -1317,7 +1317,9 @@ public class Driver implements CommandProcessor {
     int maxlen = conf.getIntVar(HiveConf.ConfVars.HIVEJOBNAMELENGTH);
 
     String queryId = plan.getQueryId();
-    String queryStr = plan.getQueryStr();
+    // Get the query string from the conf file as the compileInternal() method might
+    // hide sensitive information during query redaction.
+    String queryStr = HiveConf.getVar(conf, HiveConf.ConfVars.HIVEQUERYSTRING);
 
     maxthreads = HiveConf.getIntVar(conf, HiveConf.ConfVars.EXECPARALLETHREADNUMBER);