Return-Path: X-Original-To: apmail-hadoop-common-commits-archive@www.apache.org Delivered-To: apmail-hadoop-common-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6212F18811 for ; Mon, 6 Jul 2015 20:57:40 +0000 (UTC) Received: (qmail 59094 invoked by uid 500); 6 Jul 2015 20:57:28 -0000 Delivered-To: apmail-hadoop-common-commits-archive@hadoop.apache.org Received: (qmail 56671 invoked by uid 500); 6 Jul 2015 20:57:27 -0000 Mailing-List: contact common-commits-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: common-dev@hadoop.apache.org Delivered-To: mailing list common-commits@hadoop.apache.org Received: (qmail 53414 invoked by uid 99); 6 Jul 2015 20:57:25 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 06 Jul 2015 20:57:25 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id F0F1EE1011; Mon, 6 Jul 2015 20:57:24 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: zjshen@apache.org To: common-commits@hadoop.apache.org Date: Mon, 06 Jul 2015 20:58:06 -0000 Message-Id: In-Reply-To: <6162da200e644fdeabf9f916da3b92b4@git.apache.org> References: <6162da200e644fdeabf9f916da3b92b4@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [44/48] hadoop git commit: HDFS-8686. WebHdfsFileSystem#getXAttr(Path p, final String name) doesn't work if namespace is in capitals (Contributed by kanaka kumar avvaru) HDFS-8686. WebHdfsFileSystem#getXAttr(Path p, final String name) doesn't work if namespace is in capitals (Contributed by kanaka kumar avvaru) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/68375526 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/68375526 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/68375526 Branch: refs/heads/YARN-2928 Commit: 68375526908332b9a5ec12228937b22dc18e82a2 Parents: 7182a03 Author: Vinayakumar B Authored: Mon Jul 6 16:09:24 2015 +0530 Committer: Zhijie Shen Committed: Mon Jul 6 11:32:02 2015 -0700 ---------------------------------------------------------------------- .../org/apache/hadoop/hdfs/web/JsonUtilClient.java | 14 ++++++++++++++ .../org/apache/hadoop/hdfs/web/WebHdfsFileSystem.java | 2 +- hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt | 3 +++ .../hadoop/hdfs/server/namenode/FSXAttrBaseTest.java | 5 ++++- .../TestOfflineImageViewerForXAttr.java | 3 +++ 5 files changed, 25 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/68375526/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java index e025e31..713836c 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/JsonUtilClient.java @@ -413,6 +413,20 @@ class JsonUtilClient { return null; } + /** Expecting only single XAttr in the map. return its value */ + static byte[] getXAttr(final Map json) throws IOException { + if (json == null) { + return null; + } + + Map xAttrs = toXAttrs(json); + if (xAttrs != null && !xAttrs.values().isEmpty()) { + return xAttrs.values().iterator().next(); + } + + return null; + } + static Map toXAttrs(final Map json) throws IOException { if (json == null) { http://git-wip-us.apache.org/repos/asf/hadoop/blob/68375526/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/WebHdfsFileSystem.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/WebHdfsFileSystem.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/WebHdfsFileSystem.java index 2650dca..b661d07 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/WebHdfsFileSystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/web/WebHdfsFileSystem.java @@ -963,7 +963,7 @@ public class WebHdfsFileSystem extends FileSystem new XAttrEncodingParam(XAttrCodec.HEX)) { @Override byte[] decodeResponse(Map json) throws IOException { - return JsonUtilClient.getXAttr(json, name); + return JsonUtilClient.getXAttr(json); } }.run(); } http://git-wip-us.apache.org/repos/asf/hadoop/blob/68375526/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index 4f184fb..9edc2af 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -1005,6 +1005,9 @@ Release 2.8.0 - UNRELEASED HDFS-8577. Avoid retrying to recover lease on a file which does not exist (J.Andreina via vinayakumarb) + HDFS-8686. WebHdfsFileSystem#getXAttr(Path p, final String name) doesn't + work if namespace is in capitals (kanaka kumar avvaru via vinayakumarb) + Release 2.7.2 - UNRELEASED INCOMPATIBLE CHANGES http://git-wip-us.apache.org/repos/asf/hadoop/blob/68375526/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/FSXAttrBaseTest.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/FSXAttrBaseTest.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/FSXAttrBaseTest.java index e21e34c..eb9053c 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/FSXAttrBaseTest.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/FSXAttrBaseTest.java @@ -395,7 +395,10 @@ public class FSXAttrBaseTest { FileSystem.mkdirs(fs, path, FsPermission.createImmutable((short)0750)); fs.setXAttr(path, name1, value1, EnumSet.of(XAttrSetFlag.CREATE)); fs.setXAttr(path, name2, value2, EnumSet.of(XAttrSetFlag.CREATE)); - + + final byte[] theValue = fs.getXAttr(path, "USER.a2"); + Assert.assertArrayEquals(value2, theValue); + /* An XAttr that was requested does not exist. */ try { final byte[] value = fs.getXAttr(path, name3); http://git-wip-us.apache.org/repos/asf/hadoop/blob/68375526/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/TestOfflineImageViewerForXAttr.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/TestOfflineImageViewerForXAttr.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/TestOfflineImageViewerForXAttr.java index 3f23f64..6c82101 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/TestOfflineImageViewerForXAttr.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/TestOfflineImageViewerForXAttr.java @@ -231,6 +231,9 @@ public class TestOfflineImageViewerForXAttr { "user.attr1")); assertEquals("value1", value); + value = new String(webhdfs.getXAttr(new Path("/dir1"), "USER.attr1")); + assertEquals("value1", value); + Map contentMap = webhdfs.getXAttrs(new Path("/dir1"), names);