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

HDFS-16618. sync_file_range error should include more volume/file info (#4402) 

Signed-off-by: Tao Li <tomscut@apache.org>
This commit is contained in:
Viraj Jasani 2022-06-07 01:53:45 -07:00 committed by tom lee
parent 132fbbe228
commit 516a2a8e44
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/FsDatasetAsyncDiskService.java
View File

@ -216,16 +216,20 @@ synchronized void shutdown() {
}
}
public void submitSyncFileRangeRequest(FsVolumeImpl volume,
final ReplicaOutputStreams streams, final long offset, final long nbytes,
final int flags) {
execute(volume, new Runnable() {
@Override
public void run() {
public void submitSyncFileRangeRequest(FsVolumeImpl volume, final ReplicaOutputStreams streams,
final long offset, final long nbytes, final int flags) {
execute(volume, () -> {
try {
streams.syncFileRangeIfPossible(offset, nbytes, flags);
} catch (NativeIOException e) {
try {
streams.syncFileRangeIfPossible(offset, nbytes, flags);
} catch (NativeIOException e) {
LOG.warn("sync_file_range error", e);
LOG.warn("sync_file_range error. Volume: {}, Capacity: {}, Available space: {}, "
+ "File range offset: {}, length: {}, flags: {}", volume, volume.getCapacity(),
volume.getAvailable(), offset, nbytes, flags, e);
} catch (IOException ioe) {
LOG.warn("sync_file_range error. Volume: {}, Capacity: {}, "
+ "File range offset: {}, length: {}, flags: {}", volume, volume.getCapacity(),
offset, nbytes, flags, e);
}
}
});