|
@@ -476,7 +476,7 @@ public class S3AInputStream extends FSInputStream implements CanSetReadahead {
|
|
// and an abort is triggered, the initial attempt's statistics
|
|
// and an abort is triggered, the initial attempt's statistics
|
|
// aren't collected.
|
|
// aren't collected.
|
|
streamStatistics.streamClose(false, drained);
|
|
streamStatistics.streamClose(false, drained);
|
|
- } catch (IOException e) {
|
|
|
|
|
|
+ } catch (Exception e) {
|
|
// exception escalates to an abort
|
|
// exception escalates to an abort
|
|
LOG.debug("When closing {} stream for {}", uri, reason, e);
|
|
LOG.debug("When closing {} stream for {}", uri, reason, e);
|
|
shouldAbort = true;
|
|
shouldAbort = true;
|