HIVE-12657 : selectDistinctStar.q results differ with jdk 1.7 vs jdk 1.8 (Sergey Shelukhin, reviewed by Pengcheng Xiong)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/7feb1ca2 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/7feb1ca2 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/7feb1ca2 Branch: refs/heads/branch-2.0 Commit: 7feb1ca2ed8596ffc961f6cd220f3ba74b34b035 Parents: e86abb9 Author: Sergey Shelukhin <ser...@apache.org> Authored: Tue Jan 19 11:50:23 2016 -0800 Committer: Sergey Shelukhin <ser...@apache.org> Committed: Tue Jan 19 11:50:38 2016 -0800 ---------------------------------------------------------------------- .../JoinCondTypeCheckProcFactory.java | 4 +- .../hadoop/hive/ql/parse/CalcitePlanner.java | 1 + .../hadoop/hive/ql/parse/RowResolver.java | 31 +++++----- .../hadoop/hive/ql/parse/SemanticAnalyzer.java | 5 +- .../clientpositive/groupby_resolution.q.out | 8 +-- .../llap/selectDistinctStar.q.out | 60 ++++++++++---------- .../clientpositive/selectDistinctStar.q.out | 60 ++++++++++---------- .../spark/groupby_resolution.q.out | 8 +-- .../clientpositive/tez/selectDistinctStar.q.out | 60 ++++++++++---------- 9 files changed, 118 insertions(+), 119 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/JoinCondTypeCheckProcFactory.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/JoinCondTypeCheckProcFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/JoinCondTypeCheckProcFactory.java index 4cd01c9..9128d81 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/JoinCondTypeCheckProcFactory.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/translator/JoinCondTypeCheckProcFactory.java @@ -288,12 +288,12 @@ public class JoinCondTypeCheckProcFactory extends TypeCheckProcFactory { // inputRR. if (tableAlias != null) { if (inputRR.hasTableAlias(tableAlias)) { - if (inputRR.getInvRslvMap().containsKey(colDesc.getColumn())) { + if (inputRR.doesInvRslvMapContain(colDesc.getColumn())) { inputLineage.add(i); } } } else { - if (inputRR.getInvRslvMap().containsKey(colDesc.getColumn())) { + if (inputRR.doesInvRslvMapContain(colDesc.getColumn())) { inputLineage.add(i); } } http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java index d919880..4ce9111 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java @@ -2922,6 +2922,7 @@ public class CalcitePlanner extends SemanticAnalyzer { ExprNodeColumnDesc colExp = (ExprNodeColumnDesc) exp; String[] altMapping = inputRR.getAlternateMappings(colExp.getColumn()); if (altMapping != null) { + // TODO: this can overwrite the mapping. Should this be allowed? out_rwsch.put(altMapping[0], altMapping[1], colInfo); } } http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/java/org/apache/hadoop/hive/ql/parse/RowResolver.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/RowResolver.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/RowResolver.java index 0bd036f..5128505 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/RowResolver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/RowResolver.java @@ -38,10 +38,10 @@ import org.apache.hadoop.hive.ql.exec.RowSchema; */ public class RowResolver implements Serializable{ private static final long serialVersionUID = 1L; - private RowSchema rowSchema; - private HashMap<String, LinkedHashMap<String, ColumnInfo>> rslvMap; + private RowSchema rowSchema; + private LinkedHashMap<String, LinkedHashMap<String, ColumnInfo>> rslvMap; - private HashMap<String, String[]> invRslvMap; + private HashMap<String, String[]> invRslvMap; /* * now a Column can have an alternate mapping. * This captures the alternate mapping. @@ -58,7 +58,7 @@ public class RowResolver implements Serializable{ public RowResolver() { rowSchema = new RowSchema(); - rslvMap = new HashMap<String, LinkedHashMap<String, ColumnInfo>>(); + rslvMap = new LinkedHashMap<String, LinkedHashMap<String, ColumnInfo>>(); invRslvMap = new HashMap<String, String[]>(); altInvRslvMap = new HashMap<String, String[]>(); expressionMap = new HashMap<String, ASTNode>(); @@ -315,14 +315,10 @@ public class RowResolver implements Serializable{ return rowSchema; } - public HashMap<String, LinkedHashMap<String, ColumnInfo>> getRslvMap() { + public LinkedHashMap<String, LinkedHashMap<String, ColumnInfo>> getRslvMap() { return rslvMap; } - public HashMap<String, String[]> getInvRslvMap() { - return invRslvMap; - } - public Map<String, ASTNode> getExpressionMap() { return expressionMap; } @@ -331,19 +327,14 @@ public class RowResolver implements Serializable{ this.isExprResolver = isExprResolver; } + public boolean doesInvRslvMapContain(String column) { + return getInvRslvMap().containsKey(column); + } public void setRowSchema(RowSchema rowSchema) { this.rowSchema = rowSchema; } - public void setRslvMap(HashMap<String, LinkedHashMap<String, ColumnInfo>> rslvMap) { - this.rslvMap = rslvMap; - } - - public void setInvRslvMap(HashMap<String, String[]> invRslvMap) { - this.invRslvMap = invRslvMap; - } - public void setExpressionMap(Map<String, ASTNode> expressionMap) { this.expressionMap = expressionMap; } @@ -474,4 +465,8 @@ public class RowResolver implements Serializable{ resolver.isExprResolver = isExprResolver; return resolver; } -} \ No newline at end of file + + private HashMap<String, String[]> getInvRslvMap() { + return invRslvMap; // If making this public, note that its ordering is undefined. + } +} http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java index 1b9c170..34144e7 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java @@ -12232,8 +12232,11 @@ public class SemanticAnalyzer extends BaseSemanticAnalyzer { return false; } public static ASTNode genSelectDIAST(RowResolver rr) { - HashMap<String, LinkedHashMap<String, ColumnInfo>> map = rr.getRslvMap(); + LinkedHashMap<String, LinkedHashMap<String, ColumnInfo>> map = rr.getRslvMap(); ASTNode selectDI = new ASTNode(new CommonToken(HiveParser.TOK_SELECTDI, "TOK_SELECTDI")); + // Note: this will determine the order of columns in the result. For now, the columns for each + // table will be together; the order of the tables, as well as the columns within each + // table, is deterministic, but undefined - RR stores them in the order of addition. for (String tabAlias : map.keySet()) { for (Entry<String, ColumnInfo> entry : map.get(tabAlias).entrySet()) { selectDI.addChild(buildSelExprSubTree(tabAlias, entry.getKey())); http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/test/results/clientpositive/groupby_resolution.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/groupby_resolution.q.out b/ql/src/test/results/clientpositive/groupby_resolution.q.out index 9e58b75..0bc365c 100644 --- a/ql/src/test/results/clientpositive/groupby_resolution.q.out +++ b/ql/src/test/results/clientpositive/groupby_resolution.q.out @@ -766,14 +766,14 @@ STAGE PLANS: outputColumnNames: _col0, _col1 Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator - key expressions: _col0 (type: string) + key expressions: _col1 (type: string) sort order: + - Map-reduce partition columns: _col0 (type: string) + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - value expressions: _col1 (type: string) + value expressions: _col0 (type: string) Reduce Operator Tree: Select Operator - expressions: KEY.reducesinkkey0 (type: string), VALUE._col0 (type: string) + expressions: VALUE._col0 (type: string), KEY.reducesinkkey0 (type: string) outputColumnNames: _col0, _col1 Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE File Output Operator http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/test/results/clientpositive/llap/selectDistinctStar.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/llap/selectDistinctStar.q.out b/ql/src/test/results/clientpositive/llap/selectDistinctStar.q.out index 663d999..5594a0e 100644 --- a/ql/src/test/results/clientpositive/llap/selectDistinctStar.q.out +++ b/ql/src/test/results/clientpositive/llap/selectDistinctStar.q.out @@ -1770,17 +1770,17 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Input: default@src1 #### A masked pattern was here #### -128 128 val_128 +128 val_128 128 146 val_146 146 val_146 150 val_150 150 val_150 213 val_213 213 val_213 -224 224 val_224 +224 val_224 224 238 val_238 238 val_238 255 val_255 255 val_255 273 val_273 273 val_273 278 val_278 278 val_278 311 val_311 311 val_311 -369 369 val_369 +369 val_369 369 401 val_401 401 val_401 406 val_406 406 val_406 66 val_66 66 val_66 @@ -1803,18 +1803,18 @@ POSTHOOK: Input: default@src1 POSTHOOK: Input: default@srcpart POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 #### A masked pattern was here #### -146 val_146 2008-04-08 11 146 val_146 146 val_146 -150 val_150 2008-04-08 11 150 val_150 150 val_150 -213 val_213 2008-04-08 11 213 val_213 213 val_213 -238 val_238 2008-04-08 11 238 val_238 238 val_238 -255 val_255 2008-04-08 11 255 val_255 255 val_255 -273 val_273 2008-04-08 11 273 val_273 273 val_273 -278 val_278 2008-04-08 11 278 val_278 278 val_278 -311 val_311 2008-04-08 11 311 val_311 311 val_311 -401 val_401 2008-04-08 11 401 val_401 401 val_401 -406 val_406 2008-04-08 11 406 val_406 406 val_406 -66 val_66 2008-04-08 11 66 val_66 66 val_66 -98 val_98 2008-04-08 11 98 val_98 98 val_98 +146 val_146 146 val_146 146 val_146 2008-04-08 11 +150 val_150 150 val_150 150 val_150 2008-04-08 11 +213 val_213 213 val_213 213 val_213 2008-04-08 11 +238 val_238 238 val_238 238 val_238 2008-04-08 11 +255 val_255 255 val_255 255 val_255 2008-04-08 11 +273 val_273 273 val_273 273 val_273 2008-04-08 11 +278 val_278 278 val_278 278 val_278 2008-04-08 11 +311 val_311 311 val_311 311 val_311 2008-04-08 11 +401 val_401 401 val_401 401 val_401 2008-04-08 11 +406 val_406 406 val_406 406 val_406 2008-04-08 11 +66 val_66 66 val_66 66 val_66 2008-04-08 11 +98 val_98 98 val_98 98 val_98 2008-04-08 11 PREHOOK: query: select * from (select distinct * from src)src1 join (select distinct * from src)src2 @@ -4223,17 +4223,17 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Input: default@src1 #### A masked pattern was here #### -128 128 val_128 +128 val_128 128 146 val_146 146 val_146 150 val_150 150 val_150 213 val_213 213 val_213 -224 224 val_224 +224 val_224 224 238 val_238 238 val_238 255 val_255 255 val_255 273 val_273 273 val_273 278 val_278 278 val_278 311 val_311 311 val_311 -369 369 val_369 +369 val_369 369 401 val_401 401 val_401 406 val_406 406 val_406 66 val_66 66 val_66 @@ -4256,18 +4256,18 @@ POSTHOOK: Input: default@src1 POSTHOOK: Input: default@srcpart POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 #### A masked pattern was here #### -146 val_146 2008-04-08 11 146 val_146 146 val_146 -150 val_150 2008-04-08 11 150 val_150 150 val_150 -213 val_213 2008-04-08 11 213 val_213 213 val_213 -238 val_238 2008-04-08 11 238 val_238 238 val_238 -255 val_255 2008-04-08 11 255 val_255 255 val_255 -273 val_273 2008-04-08 11 273 val_273 273 val_273 -278 val_278 2008-04-08 11 278 val_278 278 val_278 -311 val_311 2008-04-08 11 311 val_311 311 val_311 -401 val_401 2008-04-08 11 401 val_401 401 val_401 -406 val_406 2008-04-08 11 406 val_406 406 val_406 -66 val_66 2008-04-08 11 66 val_66 66 val_66 -98 val_98 2008-04-08 11 98 val_98 98 val_98 +146 val_146 146 val_146 146 val_146 2008-04-08 11 +150 val_150 150 val_150 150 val_150 2008-04-08 11 +213 val_213 213 val_213 213 val_213 2008-04-08 11 +238 val_238 238 val_238 238 val_238 2008-04-08 11 +255 val_255 255 val_255 255 val_255 2008-04-08 11 +273 val_273 273 val_273 273 val_273 2008-04-08 11 +278 val_278 278 val_278 278 val_278 2008-04-08 11 +311 val_311 311 val_311 311 val_311 2008-04-08 11 +401 val_401 401 val_401 401 val_401 2008-04-08 11 +406 val_406 406 val_406 406 val_406 2008-04-08 11 +66 val_66 66 val_66 66 val_66 2008-04-08 11 +98 val_98 98 val_98 98 val_98 2008-04-08 11 PREHOOK: query: select * from (select distinct * from src)src1 join (select distinct * from src)src2 http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/test/results/clientpositive/selectDistinctStar.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/selectDistinctStar.q.out b/ql/src/test/results/clientpositive/selectDistinctStar.q.out index 3f44580..4e2d7c8 100644 --- a/ql/src/test/results/clientpositive/selectDistinctStar.q.out +++ b/ql/src/test/results/clientpositive/selectDistinctStar.q.out @@ -1743,17 +1743,17 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Input: default@src1 #### A masked pattern was here #### -128 128 val_128 +128 val_128 128 146 val_146 146 val_146 150 val_150 150 val_150 213 val_213 213 val_213 -224 224 val_224 +224 val_224 224 238 val_238 238 val_238 255 val_255 255 val_255 273 val_273 273 val_273 278 val_278 278 val_278 311 val_311 311 val_311 -369 369 val_369 +369 val_369 369 401 val_401 401 val_401 406 val_406 406 val_406 66 val_66 66 val_66 @@ -1776,18 +1776,18 @@ POSTHOOK: Input: default@src1 POSTHOOK: Input: default@srcpart POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 #### A masked pattern was here #### -146 val_146 2008-04-08 11 146 val_146 146 val_146 -150 val_150 2008-04-08 11 150 val_150 150 val_150 -213 val_213 2008-04-08 11 213 val_213 213 val_213 -238 val_238 2008-04-08 11 238 val_238 238 val_238 -255 val_255 2008-04-08 11 255 val_255 255 val_255 -273 val_273 2008-04-08 11 273 val_273 273 val_273 -278 val_278 2008-04-08 11 278 val_278 278 val_278 -311 val_311 2008-04-08 11 311 val_311 311 val_311 -401 val_401 2008-04-08 11 401 val_401 401 val_401 -406 val_406 2008-04-08 11 406 val_406 406 val_406 -66 val_66 2008-04-08 11 66 val_66 66 val_66 -98 val_98 2008-04-08 11 98 val_98 98 val_98 +146 val_146 146 val_146 146 val_146 2008-04-08 11 +150 val_150 150 val_150 150 val_150 2008-04-08 11 +213 val_213 213 val_213 213 val_213 2008-04-08 11 +238 val_238 238 val_238 238 val_238 2008-04-08 11 +255 val_255 255 val_255 255 val_255 2008-04-08 11 +273 val_273 273 val_273 273 val_273 2008-04-08 11 +278 val_278 278 val_278 278 val_278 2008-04-08 11 +311 val_311 311 val_311 311 val_311 2008-04-08 11 +401 val_401 401 val_401 401 val_401 2008-04-08 11 +406 val_406 406 val_406 406 val_406 2008-04-08 11 +66 val_66 66 val_66 66 val_66 2008-04-08 11 +98 val_98 98 val_98 98 val_98 2008-04-08 11 PREHOOK: query: select * from (select distinct * from src)src1 join (select distinct * from src)src2 @@ -4169,17 +4169,17 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Input: default@src1 #### A masked pattern was here #### -128 128 val_128 +128 val_128 128 146 val_146 146 val_146 150 val_150 150 val_150 213 val_213 213 val_213 -224 224 val_224 +224 val_224 224 238 val_238 238 val_238 255 val_255 255 val_255 273 val_273 273 val_273 278 val_278 278 val_278 311 val_311 311 val_311 -369 369 val_369 +369 val_369 369 401 val_401 401 val_401 406 val_406 406 val_406 66 val_66 66 val_66 @@ -4202,18 +4202,18 @@ POSTHOOK: Input: default@src1 POSTHOOK: Input: default@srcpart POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 #### A masked pattern was here #### -146 val_146 2008-04-08 11 146 val_146 146 val_146 -150 val_150 2008-04-08 11 150 val_150 150 val_150 -213 val_213 2008-04-08 11 213 val_213 213 val_213 -238 val_238 2008-04-08 11 238 val_238 238 val_238 -255 val_255 2008-04-08 11 255 val_255 255 val_255 -273 val_273 2008-04-08 11 273 val_273 273 val_273 -278 val_278 2008-04-08 11 278 val_278 278 val_278 -311 val_311 2008-04-08 11 311 val_311 311 val_311 -401 val_401 2008-04-08 11 401 val_401 401 val_401 -406 val_406 2008-04-08 11 406 val_406 406 val_406 -66 val_66 2008-04-08 11 66 val_66 66 val_66 -98 val_98 2008-04-08 11 98 val_98 98 val_98 +146 val_146 146 val_146 146 val_146 2008-04-08 11 +150 val_150 150 val_150 150 val_150 2008-04-08 11 +213 val_213 213 val_213 213 val_213 2008-04-08 11 +238 val_238 238 val_238 238 val_238 2008-04-08 11 +255 val_255 255 val_255 255 val_255 2008-04-08 11 +273 val_273 273 val_273 273 val_273 2008-04-08 11 +278 val_278 278 val_278 278 val_278 2008-04-08 11 +311 val_311 311 val_311 311 val_311 2008-04-08 11 +401 val_401 401 val_401 401 val_401 2008-04-08 11 +406 val_406 406 val_406 406 val_406 2008-04-08 11 +66 val_66 66 val_66 66 val_66 2008-04-08 11 +98 val_98 98 val_98 98 val_98 2008-04-08 11 PREHOOK: query: select * from (select distinct * from src)src1 join (select distinct * from src)src2 http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/test/results/clientpositive/spark/groupby_resolution.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/spark/groupby_resolution.q.out b/ql/src/test/results/clientpositive/spark/groupby_resolution.q.out index cef5b23..72f48ee 100644 --- a/ql/src/test/results/clientpositive/spark/groupby_resolution.q.out +++ b/ql/src/test/results/clientpositive/spark/groupby_resolution.q.out @@ -765,15 +765,15 @@ STAGE PLANS: outputColumnNames: _col0, _col1 Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE Reduce Output Operator - key expressions: _col0 (type: string) + key expressions: _col1 (type: string) sort order: + - Map-reduce partition columns: _col0 (type: string) + Map-reduce partition columns: _col1 (type: string) Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE - value expressions: _col1 (type: string) + value expressions: _col0 (type: string) Reducer 2 Reduce Operator Tree: Select Operator - expressions: KEY.reducesinkkey0 (type: string), VALUE._col0 (type: string) + expressions: VALUE._col0 (type: string), KEY.reducesinkkey0 (type: string) outputColumnNames: _col0, _col1 Statistics: Num rows: 500 Data size: 5312 Basic stats: COMPLETE Column stats: NONE File Output Operator http://git-wip-us.apache.org/repos/asf/hive/blob/7feb1ca2/ql/src/test/results/clientpositive/tez/selectDistinctStar.q.out ---------------------------------------------------------------------- diff --git a/ql/src/test/results/clientpositive/tez/selectDistinctStar.q.out b/ql/src/test/results/clientpositive/tez/selectDistinctStar.q.out index 22ac115..bf665aa 100644 --- a/ql/src/test/results/clientpositive/tez/selectDistinctStar.q.out +++ b/ql/src/test/results/clientpositive/tez/selectDistinctStar.q.out @@ -1763,17 +1763,17 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Input: default@src1 #### A masked pattern was here #### -128 128 val_128 +128 val_128 128 146 val_146 146 val_146 150 val_150 150 val_150 213 val_213 213 val_213 -224 224 val_224 +224 val_224 224 238 val_238 238 val_238 255 val_255 255 val_255 273 val_273 273 val_273 278 val_278 278 val_278 311 val_311 311 val_311 -369 369 val_369 +369 val_369 369 401 val_401 401 val_401 406 val_406 406 val_406 66 val_66 66 val_66 @@ -1796,18 +1796,18 @@ POSTHOOK: Input: default@src1 POSTHOOK: Input: default@srcpart POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 #### A masked pattern was here #### -146 val_146 2008-04-08 11 146 val_146 146 val_146 -150 val_150 2008-04-08 11 150 val_150 150 val_150 -213 val_213 2008-04-08 11 213 val_213 213 val_213 -238 val_238 2008-04-08 11 238 val_238 238 val_238 -255 val_255 2008-04-08 11 255 val_255 255 val_255 -273 val_273 2008-04-08 11 273 val_273 273 val_273 -278 val_278 2008-04-08 11 278 val_278 278 val_278 -311 val_311 2008-04-08 11 311 val_311 311 val_311 -401 val_401 2008-04-08 11 401 val_401 401 val_401 -406 val_406 2008-04-08 11 406 val_406 406 val_406 -66 val_66 2008-04-08 11 66 val_66 66 val_66 -98 val_98 2008-04-08 11 98 val_98 98 val_98 +146 val_146 146 val_146 146 val_146 2008-04-08 11 +150 val_150 150 val_150 150 val_150 2008-04-08 11 +213 val_213 213 val_213 213 val_213 2008-04-08 11 +238 val_238 238 val_238 238 val_238 2008-04-08 11 +255 val_255 255 val_255 255 val_255 2008-04-08 11 +273 val_273 273 val_273 273 val_273 2008-04-08 11 +278 val_278 278 val_278 278 val_278 2008-04-08 11 +311 val_311 311 val_311 311 val_311 2008-04-08 11 +401 val_401 401 val_401 401 val_401 2008-04-08 11 +406 val_406 406 val_406 406 val_406 2008-04-08 11 +66 val_66 66 val_66 66 val_66 2008-04-08 11 +98 val_98 98 val_98 98 val_98 2008-04-08 11 PREHOOK: query: select * from (select distinct * from src)src1 join (select distinct * from src)src2 @@ -4209,17 +4209,17 @@ POSTHOOK: type: QUERY POSTHOOK: Input: default@src POSTHOOK: Input: default@src1 #### A masked pattern was here #### -128 128 val_128 +128 val_128 128 146 val_146 146 val_146 150 val_150 150 val_150 213 val_213 213 val_213 -224 224 val_224 +224 val_224 224 238 val_238 238 val_238 255 val_255 255 val_255 273 val_273 273 val_273 278 val_278 278 val_278 311 val_311 311 val_311 -369 369 val_369 +369 val_369 369 401 val_401 401 val_401 406 val_406 406 val_406 66 val_66 66 val_66 @@ -4242,18 +4242,18 @@ POSTHOOK: Input: default@src1 POSTHOOK: Input: default@srcpart POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=11 #### A masked pattern was here #### -146 val_146 2008-04-08 11 146 val_146 146 val_146 -150 val_150 2008-04-08 11 150 val_150 150 val_150 -213 val_213 2008-04-08 11 213 val_213 213 val_213 -238 val_238 2008-04-08 11 238 val_238 238 val_238 -255 val_255 2008-04-08 11 255 val_255 255 val_255 -273 val_273 2008-04-08 11 273 val_273 273 val_273 -278 val_278 2008-04-08 11 278 val_278 278 val_278 -311 val_311 2008-04-08 11 311 val_311 311 val_311 -401 val_401 2008-04-08 11 401 val_401 401 val_401 -406 val_406 2008-04-08 11 406 val_406 406 val_406 -66 val_66 2008-04-08 11 66 val_66 66 val_66 -98 val_98 2008-04-08 11 98 val_98 98 val_98 +146 val_146 146 val_146 146 val_146 2008-04-08 11 +150 val_150 150 val_150 150 val_150 2008-04-08 11 +213 val_213 213 val_213 213 val_213 2008-04-08 11 +238 val_238 238 val_238 238 val_238 2008-04-08 11 +255 val_255 255 val_255 255 val_255 2008-04-08 11 +273 val_273 273 val_273 273 val_273 2008-04-08 11 +278 val_278 278 val_278 278 val_278 2008-04-08 11 +311 val_311 311 val_311 311 val_311 2008-04-08 11 +401 val_401 401 val_401 401 val_401 2008-04-08 11 +406 val_406 406 val_406 406 val_406 2008-04-08 11 +66 val_66 66 val_66 66 val_66 2008-04-08 11 +98 val_98 98 val_98 98 val_98 2008-04-08 11 PREHOOK: query: select * from (select distinct * from src)src1 join (select distinct * from src)src2