HADOOP-10326. M/R jobs can not access S3 if Kerberos is enabled. Contributed by bc Wong.
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1566966 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
7ce60ec1fa
commit
b5df324d32
hadoop-common-project/hadoop-common
|
@ -33,6 +33,9 @@ Release 2.4.0 - UNRELEASED
|
||||||
HADOOP-10330. TestFrameDecoder fails if it cannot bind port 12345.
|
HADOOP-10330. TestFrameDecoder fails if it cannot bind port 12345.
|
||||||
(Arpit Agarwal)
|
(Arpit Agarwal)
|
||||||
|
|
||||||
|
HADOOP-10326. M/R jobs can not access S3 if Kerberos is enabled. (bc Wong
|
||||||
|
via atm)
|
||||||
|
|
||||||
Release 2.3.0 - UNRELEASED
|
Release 2.3.0 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -350,6 +350,12 @@ public class S3FileSystem extends FileSystem {
|
||||||
return getConf().getLong("fs.s3.block.size", 64 * 1024 * 1024);
|
return getConf().getLong("fs.s3.block.size", 64 * 1024 * 1024);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getCanonicalServiceName() {
|
||||||
|
// Does not support Token
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
// diagnostic methods
|
// diagnostic methods
|
||||||
|
|
||||||
void dump() throws IOException {
|
void dump() throws IOException {
|
||||||
|
|
|
@ -699,4 +699,10 @@ public class NativeS3FileSystem extends FileSystem {
|
||||||
public Path getWorkingDirectory() {
|
public Path getWorkingDirectory() {
|
||||||
return workingDir;
|
return workingDir;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getCanonicalServiceName() {
|
||||||
|
// Does not support Token
|
||||||
|
return null;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -55,4 +55,9 @@ public abstract class S3FileSystemContractBaseTest
|
||||||
fs.getFileStatus(file).getBlockSize());
|
fs.getFileStatus(file).getBlockSize());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void testCanonicalName() throws Exception {
|
||||||
|
assertNull("s3 doesn't support security token and shouldn't have canonical name",
|
||||||
|
fs.getCanonicalServiceName());
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -49,6 +49,11 @@ public abstract class NativeS3FileSystemContractBaseTest
|
||||||
super.tearDown();
|
super.tearDown();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void testCanonicalName() throws Exception {
|
||||||
|
assertNull("s3n doesn't support security token and shouldn't have canonical name",
|
||||||
|
fs.getCanonicalServiceName());
|
||||||
|
}
|
||||||
|
|
||||||
public void testListStatusForRoot() throws Exception {
|
public void testListStatusForRoot() throws Exception {
|
||||||
FileStatus[] paths = fs.listStatus(path("/"));
|
FileStatus[] paths = fs.listStatus(path("/"));
|
||||||
assertEquals(0, paths.length);
|
assertEquals(0, paths.length);
|
||||||
|
|
Loading…
Reference in New Issue