Index: shims/src/common/java/org/apache/hadoop/hive/shims/ShimLoader.java =================================================================== --- shims/src/common/java/org/apache/hadoop/hive/shims/ShimLoader.java +++ shims/src/common/java/org/apache/hadoop/hive/shims/ShimLoader.java @@ -17,6 +17,7 @@ */ package org.apache.hadoop.hive.shims; +import java.lang.IllegalArgumentException; import java.util.HashMap; import java.util.Map; @@ -116,9 +117,18 @@ throw new RuntimeException("Illegal Hadoop Version: " + vers + " (expected A.B.* format)"); } - if (Integer.parseInt(parts[0]) > 0){ + + switch (Integer.parseInt(parts[0])) { + case 0: + break; + case 1: return "0.20S"; + case 2: + return "0.23"; + default: + throw new IllegalArgumentException("Unrecognized Hadoop major version number: " + vers); } + String majorVersion = parts[0] + "." + parts[1]; // If we are running a security release, we won't have UnixUserGroupInformation