big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HADOOP-16202. Enhanced openFile(): hadoop-azure changes. (#2584/4)

Browse Source 
Stops the abfs connector warning if openFile().withFileStatus()
is invoked with a FileStatus is not an abfs VersionedFileStatus.

Contributed by Steve Loughran.

Change-Id: I85076b365eb30aaef2ed35139fa8714efd4d048e
This commit is contained in:
Steve Loughran 2022-04-24 17:30:41 +01:00
parent e0cd0a82e0
commit 44ae2fa8e5
No known key found for this signature in database
GPG Key ID: D22CF846DBB162A0
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java
View File

@ -766,7 +766,7 @@ public AbfsInputStream openFileForRead(Path path,
eTag = ((VersionedFileStatus) fileStatus).getVersion(); eTag = ((VersionedFileStatus) fileStatus).getVersion();
} else { } else {
if (fileStatus != null) { if (fileStatus != null) {
LOG.warn( LOG.debug(
"Fallback to getPathStatus REST call as provided filestatus " "Fallback to getPathStatus REST call as provided filestatus "
+ "is not of type VersionedFileStatus"); + "is not of type VersionedFileStatus");
} }

2
hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/contract/ITestAbfsFileSystemContractSeek.java
View File

@ -37,7 +37,7 @@
import static org.apache.hadoop.fs.azurebfs.constants.FileSystemConfigurations.MIN_BUFFER_SIZE; import static org.apache.hadoop.fs.azurebfs.constants.FileSystemConfigurations.MIN_BUFFER_SIZE;
import static org.apache.hadoop.fs.contract.ContractTestUtils.createFile; import static org.apache.hadoop.fs.contract.ContractTestUtils.createFile;
import static org.apache.hadoop.fs.contract.ContractTestUtils.dataset; import static org.apache.hadoop.fs.contract.ContractTestUtils.dataset;
import static org.apache.hadoop.fs.impl.FutureIOSupport.awaitFuture; import static org.apache.hadoop.util.functional.FutureIO.awaitFuture;
/** /**
* Contract test for seek operation. * Contract test for seek operation.