This is an automated email from the ASF dual-hosted git repository.
sammichen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 565972c Support more detailed error log when handleFlush in Ozone
client (#2795)
565972c is described below
commit 565972c162819dc4f57d17e4b47f2f47e3bd9c55
Author: micah zhao <[email protected]>
AuthorDate: Thu Nov 4 12:01:47 2021 +0800
Support more detailed error log when handleFlush in Ozone client (#2795)
---
.../org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git
a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java
b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java
index 0cfbb5a..859d808 100644
---
a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java
+++
b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/storage/BlockOutputStream.java
@@ -484,6 +484,10 @@ public class BlockOutputStream extends OutputStream {
} catch (InterruptedException ex) {
Thread.currentThread().interrupt();
handleInterruptedException(ex, true);
+ } catch (Throwable e) {
+ String msg = "Failed to flush. error: " + e.getMessage();
+ LOG.error(msg, e);
+ throw new RuntimeException(msg, e);
}
}
}
@@ -546,6 +550,10 @@ public class BlockOutputStream extends OutputStream {
} catch (InterruptedException ex) {
Thread.currentThread().interrupt();
handleInterruptedException(ex, true);
+ } catch (Throwable e) {
+ String msg = "Failed to flush. error: " + e.getMessage();
+ LOG.error(msg, e);
+ throw new RuntimeException(msg, e);
} finally {
cleanup(false);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
