diff --git a/client/src/main/java/org/apache/sqoop/client/request/ResourceRequest.java b/client/src/main/java/org/apache/sqoop/client/request/ResourceRequest.java index db161077..3c4a4d23 100644 --- a/client/src/main/java/org/apache/sqoop/client/request/ResourceRequest.java +++ b/client/src/main/java/org/apache/sqoop/client/request/ResourceRequest.java @@ -56,8 +56,6 @@ protected String doHttpRequest(String strURL, String method, String data) { HttpURLConnection conn = new AuthenticatedURL().openConnection(url, token); conn.setRequestMethod(method); -// Provide name of user executing request - conn.setRequestProperty(SqoopProtocolConstants.HEADER_SQOOP_USERNAME, System.getProperty("user.name")); // Sqoop is using JSON for data transfers conn.setRequestProperty("Accept", MediaType.APPLICATION_JSON); // Transfer client locale to return client specific data diff --git a/common/src/main/java/org/apache/sqoop/common/SqoopProtocolConstants.java b/common/src/main/java/org/apache/sqoop/common/SqoopProtocolConstants.java index d08c855d..8f4f7091 100644 --- a/common/src/main/java/org/apache/sqoop/common/SqoopProtocolConstants.java +++ b/common/src/main/java/org/apache/sqoop/common/SqoopProtocolConstants.java @@ -18,8 +18,6 @@ package org.apache.sqoop.common; public final class SqoopProtocolConstants { - public static final String HEADER_SQOOP_USERNAME = "sqoop-user-name"; - public static final String HEADER_SQOOP_ERROR_CODE = "sqoop-error-code"; public static final String HEADER_SQOOP_ERROR_MESSAGE = "sqoop-error-message"; diff --git a/server/src/main/java/org/apache/sqoop/server/RequestContext.java b/server/src/main/java/org/apache/sqoop/server/RequestContext.java index 54e9cca0..d0963f5b 100644 --- a/server/src/main/java/org/apache/sqoop/server/RequestContext.java +++ b/server/src/main/java/org/apache/sqoop/server/RequestContext.java @@ -17,8 +17,8 @@ */ package org.apache.sqoop.server; +import org.apache.hadoop.security.authentication.client.PseudoAuthenticator; import org.apache.sqoop.common.SqoopException; -import org.apache.sqoop.common.SqoopProtocolConstants; import org.apache.sqoop.server.common.ServerError; import javax.servlet.http.HttpServletRequest; @@ -119,6 +119,6 @@ public Locale getAcceptLanguageHeader() { * @return Name of user sending the request */ public String getUserName() { - return request.getHeader(SqoopProtocolConstants.HEADER_SQOOP_USERNAME); + return request.getParameter(PseudoAuthenticator.USER_NAME); } }