HIVE-11821: JDK8 strict build broken for master (Gopal V, reviewed by Sergey Shelukhin)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/bc62a46d Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/bc62a46d Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/bc62a46d Branch: refs/heads/spark Commit: bc62a46d1a19f343fc74319c52f14a812f3c70fb Parents: c689589 Author: Gopal V <[email protected]> Authored: Tue Sep 15 17:21:36 2015 -0700 Committer: Gopal V <[email protected]> Committed: Tue Sep 15 17:21:50 2015 -0700 ---------------------------------------------------------------------- .../org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/bc62a46d/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java index 8ea1879..c357329 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java @@ -19,6 +19,7 @@ package org.apache.hadoop.hive.ql.optimizer; import java.util.ArrayList; +import java.util.Collection; import java.util.HashMap; import java.util.HashSet; import java.util.List; @@ -350,8 +351,9 @@ public class ConvertJoinMapJoin implements NodeProcessor { // each side better have 0 or more RS. if either side is unbalanced, cannot convert. // This is a workaround for now. Right fix would be to refactor code in the // MapRecordProcessor and ReduceRecordProcessor with respect to the sources. + @SuppressWarnings({"rawtypes","unchecked"}) Set<ReduceSinkOperator> set = - OperatorUtils.findOperatorsUpstream(parentOp.getParentOperators(), + OperatorUtils.findOperatorsUpstream((Collection)parentOp.getParentOperators(), ReduceSinkOperator.class); if (size < 0) { size = set.size();
