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

HDFS-16330. Fix incorrect placeholder for Exception logs in DiskBalancer (#3672)

Browse Source 
Signed-off-by: Akira Ajisaka <aajisaka@apache.org>
This commit is contained in:
Viraj Jasani 2021-11-18 21:25:39 +05:30 committed by GitHub
parent dc751df63b
commit 38614d05e1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DiskBalancer.java
View File

@ -989,7 +989,7 @@ private void closePoolIters(List<FsVolumeSpi.BlockIterator> poolIters) {
try { try {
iter.close(); iter.close();
} catch (IOException ex) { } catch (IOException ex) {
LOG.error("Error closing a block pool iter. ex: {}", ex); LOG.error("Error closing a block pool iter. ex: ", ex);
} }
} }
} }
@ -1124,7 +1124,7 @@ public void copyBlocks(VolumePair pair, DiskBalancerWorkItem item) {
startTime); startTime);
item.setSecondsElapsed(secondsElapsed); item.setSecondsElapsed(secondsElapsed);
} catch (IOException ex) { } catch (IOException ex) {
LOG.error("Exception while trying to copy blocks. error: {}", ex); LOG.error("Exception while trying to copy blocks. error: ", ex);
item.incErrorCount(); item.incErrorCount();
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOG.error("Copy Block Thread interrupted, exiting the copy."); LOG.error("Copy Block Thread interrupted, exiting the copy.");
@ -1133,7 +1133,7 @@ public void copyBlocks(VolumePair pair, DiskBalancerWorkItem item) {
this.setExitFlag(); this.setExitFlag();
} catch (RuntimeException ex) { } catch (RuntimeException ex) {
// Exiting if any run time exceptions. // Exiting if any run time exceptions.
LOG.error("Got an unexpected Runtime Exception {}", ex); LOG.error("Got an unexpected Runtime Exception ", ex);
item.incErrorCount(); item.incErrorCount();
this.setExitFlag(); this.setExitFlag();
} }