Author: gates
Date: Tue Mar 25 21:48:06 2014
New Revision: 1581542
URL: http://svn.apache.org/r1581542
Log:
HIVE-6671 WebHCat Job Submission API 'enablelog' parameter is only supported
with Hadoop 1 (Eugene Koifman via gates)
Modified:
hive/branches/branch-0.13/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java
Modified:
hive/branches/branch-0.13/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java
URL:
http://svn.apache.org/viewvc/hive/branches/branch-0.13/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java?rev=1581542&r1=1581541&r2=1581542&view=diff
==============================================================================
---
hive/branches/branch-0.13/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java
(original)
+++
hive/branches/branch-0.13/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/Server.java
Tue Mar 25 21:48:06 2014
@@ -48,6 +48,7 @@ import javax.ws.rs.core.UriInfo;
import org.apache.commons.exec.ExecuteException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.hive.shims.ShimLoader;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.security.authentication.client.PseudoAuthenticator;
import org.apache.hive.hcatalog.templeton.LauncherDelegator.JobType;
@@ -1155,5 +1156,8 @@ public class Server {
private void checkEnableLogPrerequisite(boolean enablelog, String statusdir)
throws BadParam {
if (enablelog && !TempletonUtils.isset(statusdir))
throw new BadParam("enablelog is only applicable when statusdir is set");
+ if(enablelog && "0.23".equalsIgnoreCase(ShimLoader.getMajorVersion())) {
+ throw new BadParam("enablelog=true is only supported with Hadoop 1.x");
+ }
}
}