Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HADOOP-15506. Upgrade Azure Storage Sdk version to 7.0.0 and update corresponding code blocks. 

Contributed by Esfandiar Manii.
This commit is contained in:
Steve Loughran 2018-06-06 18:28:14 +01:00
parent 30f0582f2b
commit d901be6795
No known key found for this signature in database
GPG Key ID: D22CF846DBB162A0
3 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-project/pom.xml
View File

@ -1333,7 +1333,7 @@
<dependency> <dependency>
<groupId>com.microsoft.azure</groupId> <groupId>com.microsoft.azure</groupId>
<artifactId>azure-storage</artifactId> <artifactId>azure-storage</artifactId>
<version>5.4.0</version> <version>7.0.0</version>
</dependency> </dependency>
<dependency> <dependency>

4
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azure/NativeAzureFileSystemHelper.java
View File

@ -87,8 +87,10 @@ final class NativeAzureFileSystemHelper {
if (errorCode != null if (errorCode != null
&& (errorCode.equals(StorageErrorCodeStrings.BLOB_NOT_FOUND) && (errorCode.equals(StorageErrorCodeStrings.BLOB_NOT_FOUND)
|| errorCode.equals(StorageErrorCodeStrings.RESOURCE_NOT_FOUND) || errorCode.equals(StorageErrorCodeStrings.RESOURCE_NOT_FOUND)
|| errorCode.equals(StorageErrorCodeStrings.CONTAINER_NOT_FOUND)
|| errorCode.equals(StorageErrorCode.BLOB_NOT_FOUND.toString()) || errorCode.equals(StorageErrorCode.BLOB_NOT_FOUND.toString())
|| errorCode.equals(StorageErrorCode.RESOURCE_NOT_FOUND.toString()))) { || errorCode.equals(StorageErrorCode.RESOURCE_NOT_FOUND.toString())
|| errorCode.equals(StorageErrorCode.CONTAINER_NOT_FOUND.toString()))) {
return true; return true;
} }

9
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azure/ITestContainerChecks.java
View File

@ -75,7 +75,7 @@ public class ITestContainerChecks extends AbstractWasbTestWithTimeout {
assertTrue("Should've thrown.", false); assertTrue("Should've thrown.", false);
} catch (FileNotFoundException ex) { } catch (FileNotFoundException ex) {
assertTrue("Unexpected exception: " + ex, assertTrue("Unexpected exception: " + ex,
ex.getMessage().contains("does not exist.")); ex.getMessage().contains("is not found"));
} }
assertFalse(container.exists()); assertFalse(container.exists());
@ -115,7 +115,7 @@ public class ITestContainerChecks extends AbstractWasbTestWithTimeout {
assertTrue("Should've thrown.", false); assertTrue("Should've thrown.", false);
} catch (FileNotFoundException ex) { } catch (FileNotFoundException ex) {
assertTrue("Unexpected exception: " + ex, assertTrue("Unexpected exception: " + ex,
ex.getMessage().contains("does not exist.")); ex.getMessage().contains("is not found"));
} }
assertFalse(container.exists()); assertFalse(container.exists());
@ -143,7 +143,7 @@ public class ITestContainerChecks extends AbstractWasbTestWithTimeout {
assertTrue("Should've thrown.", false); assertTrue("Should've thrown.", false);
} catch (FileNotFoundException ex) { } catch (FileNotFoundException ex) {
assertTrue("Unexpected exception: " + ex, assertTrue("Unexpected exception: " + ex,
ex.getMessage().contains("does not exist.")); ex.getMessage().contains("is not found"));
} }
assertFalse(container.exists()); assertFalse(container.exists());
@ -165,6 +165,9 @@ public class ITestContainerChecks extends AbstractWasbTestWithTimeout {
assertFalse(fs.rename(foo, bar)); assertFalse(fs.rename(foo, bar));
assertFalse(container.exists()); assertFalse(container.exists());
// Create a container outside of the WASB FileSystem
container.create();
// But a write should. // But a write should.
assertTrue(fs.createNewFile(foo)); assertTrue(fs.createNewFile(foo));
assertTrue(container.exists()); assertTrue(container.exists());