|
@@ -19,7 +19,6 @@ package org.apache.hadoop.hdfs.server.namenode.web.resources;
|
|
|
|
|
|
import java.io.FileNotFoundException;
|
|
|
import java.io.IOException;
|
|
|
-import java.io.InputStream;
|
|
|
import java.io.OutputStream;
|
|
|
import java.io.PrintStream;
|
|
|
import java.net.URI;
|
|
@@ -135,7 +134,8 @@ public class NamenodeWebHdfsMethods {
|
|
|
final NameNode namenode, final UserGroupInformation ugi,
|
|
|
final String renewer) throws IOException {
|
|
|
final Credentials c = DelegationTokenSecretManager.createCredentials(
|
|
|
- namenode, ugi, request.getUserPrincipal().getName());
|
|
|
+ namenode, ugi,
|
|
|
+ renewer != null? renewer: request.getUserPrincipal().getName());
|
|
|
final Token<? extends TokenIdentifier> t = c.getAllTokens().iterator().next();
|
|
|
t.setKind(WebHdfsFileSystem.TOKEN_KIND);
|
|
|
SecurityUtil.setTokenService(t, namenode.getNameNodeAddress());
|
|
@@ -180,7 +180,6 @@ public class NamenodeWebHdfsMethods {
|
|
|
@Consumes({"*/*"})
|
|
|
@Produces({MediaType.APPLICATION_JSON})
|
|
|
public Response put(
|
|
|
- final InputStream in,
|
|
|
@Context final UserGroupInformation ugi,
|
|
|
@QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
|
|
|
final DelegationParam delegation,
|
|
@@ -207,7 +206,7 @@ public class NamenodeWebHdfsMethods {
|
|
|
final ModificationTimeParam modificationTime,
|
|
|
@QueryParam(AccessTimeParam.NAME) @DefaultValue(AccessTimeParam.DEFAULT)
|
|
|
final AccessTimeParam accessTime
|
|
|
- ) throws IOException, URISyntaxException, InterruptedException {
|
|
|
+ ) throws IOException, InterruptedException {
|
|
|
|
|
|
if (LOG.isTraceEnabled()) {
|
|
|
LOG.trace(op + ": " + path + ", ugi=" + ugi
|
|
@@ -298,7 +297,6 @@ public class NamenodeWebHdfsMethods {
|
|
|
@Consumes({"*/*"})
|
|
|
@Produces({MediaType.APPLICATION_JSON})
|
|
|
public Response post(
|
|
|
- final InputStream in,
|
|
|
@Context final UserGroupInformation ugi,
|
|
|
@QueryParam(DelegationParam.NAME) @DefaultValue(DelegationParam.DEFAULT)
|
|
|
final DelegationParam delegation,
|
|
@@ -307,7 +305,7 @@ public class NamenodeWebHdfsMethods {
|
|
|
final PostOpParam op,
|
|
|
@QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
|
|
|
final BufferSizeParam bufferSize
|
|
|
- ) throws IOException, URISyntaxException, InterruptedException {
|
|
|
+ ) throws IOException, InterruptedException {
|
|
|
|
|
|
if (LOG.isTraceEnabled()) {
|
|
|
LOG.trace(op + ": " + path + ", ugi=" + ugi
|
|
@@ -384,7 +382,7 @@ public class NamenodeWebHdfsMethods {
|
|
|
final RenewerParam renewer,
|
|
|
@QueryParam(BufferSizeParam.NAME) @DefaultValue(BufferSizeParam.DEFAULT)
|
|
|
final BufferSizeParam bufferSize
|
|
|
- ) throws IOException, URISyntaxException, InterruptedException {
|
|
|
+ ) throws IOException, InterruptedException {
|
|
|
|
|
|
if (LOG.isTraceEnabled()) {
|
|
|
LOG.trace(op + ": " + path + ", ugi=" + ugi
|