ThomasMarquardt commented on a change in pull request #1791: HADOOP-16785: wasb
to raise IOE if write() invoked on a closed stream
URL: https://github.com/apache/hadoop/pull/1791#discussion_r363422859
##########
File path:
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services/AbfsOutputStream.java
##########
@@ -259,7 +259,15 @@ public synchronized void close() throws IOException {
}
private synchronized void flushInternal(boolean isClose) throws IOException {
- maybeThrowLastError();
+ try {
+ maybeThrowLastError();
+ } catch (IOException e) {
+ if (isClose) {
+ // wrap existing exception so as to avoid breaking try-with-resources
+ throw new IOException("Skipping final flush and write due to " + e, e);
+ } else
+ throw e;
+ }
Review comment:
Instead, I think we should update AbfsOutputStream.close to wrap the
exception, short of having the Java implementers fix this. :)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
