You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by zh...@apache.org on 2015/01/30 22:43:50 UTC
[6/9] hadoop git commit: HADOOP-11523. StorageException complaining "
no lease ID" when updating FolderLastModifiedTime in WASB. Contributed by Duo
Xu.
HADOOP-11523. StorageException complaining " no lease ID" when updating FolderLastModifiedTime in WASB. Contributed by Duo Xu.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/cec31660
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/cec31660
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/cec31660
Branch: refs/heads/HDFS-EC
Commit: cec31660e3e23bcc363b0e67ae1f24c47d69799a
Parents: 8de7e21
Author: cnauroth <cn...@apache.org>
Authored: Thu Jan 29 17:02:38 2015 -0800
Committer: Zhe Zhang <zh...@apache.org>
Committed: Fri Jan 30 13:42:05 2015 -0800
----------------------------------------------------------------------
hadoop-common-project/hadoop-common/CHANGES.txt | 3 ++
.../hadoop/fs/azure/NativeAzureFileSystem.java | 32 +++++++++++++++++++-
2 files changed, 34 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/cec31660/hadoop-common-project/hadoop-common/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-common-project/hadoop-common/CHANGES.txt b/hadoop-common-project/hadoop-common/CHANGES.txt
index c71d35a..f26177d 100644
--- a/hadoop-common-project/hadoop-common/CHANGES.txt
+++ b/hadoop-common-project/hadoop-common/CHANGES.txt
@@ -797,6 +797,9 @@ Release 2.7.0 - UNRELEASED
HADOOP-11403. Avoid using sys_errlist on Solaris, which lacks support for it
(Malcolm Kavalsky via Colin P. McCabe)
+ HADOOP-11523. StorageException complaining " no lease ID" when updating
+ FolderLastModifiedTime in WASB. (Duo Xu via cnauroth)
+
Release 2.6.1 - UNRELEASED
INCOMPATIBLE CHANGES
http://git-wip-us.apache.org/repos/asf/hadoop/blob/cec31660/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/NativeAzureFileSystem.java
----------------------------------------------------------------------
diff --git a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/NativeAzureFileSystem.java b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/NativeAzureFileSystem.java
index c136002..0248b85 100644
--- a/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/NativeAzureFileSystem.java
+++ b/hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/NativeAzureFileSystem.java
@@ -2040,7 +2040,37 @@ public class NativeAzureFileSystem extends FileSystem {
createPermissionStatus(FsPermission.getDefault()));
}
- store.updateFolderLastModifiedTime(parentKey, null);
+ if (store.isAtomicRenameKey(parentKey)) {
+ SelfRenewingLease lease = null;
+ try {
+ lease = leaseSourceFolder(parentKey);
+ store.updateFolderLastModifiedTime(parentKey, lease);
+ } catch (AzureException e) {
+ String errorCode = "";
+ try {
+ StorageException e2 = (StorageException) e.getCause();
+ errorCode = e2.getErrorCode();
+ } catch (Exception e3) {
+ // do nothing if cast fails
+ }
+ if (errorCode.equals("BlobNotFound")) {
+ throw new FileNotFoundException("Folder does not exist: " + parentKey);
+ }
+ LOG.warn("Got unexpected exception trying to get lease on "
+ + parentKey + ". " + e.getMessage());
+ throw e;
+ } finally {
+ try {
+ if (lease != null) {
+ lease.free();
+ }
+ } catch (Exception e) {
+ LOG.error("Unable to free lease on " + parentKey, e);
+ }
+ }
+ } else {
+ store.updateFolderLastModifiedTime(parentKey, null);
+ }
}
}
}