Repository: incubator-impala Updated Branches: refs/heads/hadoop-next cc603eb15 -> 3cb3f34d6
IMPALA-4277: remove references for unsupported s3/s3n connectors We only support s3a://. Support will be removed for s3:// in Hadoop 3.0 by HADOOP-12709 Change-Id: Ibfadd2bc91c7dbcb6f2bc962c404caea30f9b776 Reviewed-on: http://gerrit.cloudera.org:8080/4748 Reviewed-by: Tim Armstrong <[email protected]> Tested-by: Tim Armstrong <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-impala/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-impala/commit/3cb3f34d Tree: http://git-wip-us.apache.org/repos/asf/incubator-impala/tree/3cb3f34d Diff: http://git-wip-us.apache.org/repos/asf/incubator-impala/diff/3cb3f34d Branch: refs/heads/hadoop-next Commit: 3cb3f34d6d65bf52b2b8ba57a02d9ac785c8a937 Parents: cc603eb Author: Tim Armstrong <[email protected]> Authored: Tue Oct 18 13:26:37 2016 -0700 Committer: Tim Armstrong <[email protected]> Committed: Tue Oct 18 21:16:55 2016 +0000 ---------------------------------------------------------------------- fe/src/main/java/org/apache/impala/common/FileSystemUtil.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/3cb3f34d/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java ---------------------------------------------------------------------- diff --git a/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java b/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java index fbf8478..a47cc95 100644 --- a/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java +++ b/fe/src/main/java/org/apache/impala/common/FileSystemUtil.java @@ -30,9 +30,7 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.fs.LocalFileSystem; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.fs.s3.S3FileSystem; import org.apache.hadoop.fs.s3a.S3AFileSystem; -import org.apache.hadoop.fs.s3native.NativeS3FileSystem; import org.apache.hadoop.hdfs.DistributedFileSystem; import org.apache.hadoop.hdfs.client.HdfsAdmin; import org.apache.hadoop.hdfs.protocol.EncryptionZone; @@ -280,8 +278,7 @@ public class FileSystemUtil { // Common case. if (isDistributedFileSystem(fs)) return true; // Blacklist FileSystems that are known to not implement getFileBlockLocations(). - return !(fs instanceof S3AFileSystem || fs instanceof NativeS3FileSystem || - fs instanceof S3FileSystem || fs instanceof LocalFileSystem); + return !(fs instanceof S3AFileSystem|| fs instanceof LocalFileSystem); } /**
