Reviewed-by: He Xiaoqiao <hexiaoqiao@apache.org> (cherry picked from commit 5dd859a8a0d038ff04acbb96741a215d6a0e8c29)
@@ -281,7 +281,10 @@ public class FileIoProvider {
waitTime, transferTime);
profilingEventHook.afterFileIo(volume, TRANSFER, begin, count);
} catch (Exception e) {
- onFailure(volume, begin);
+ String em = e.getMessage();
+ if (!em.startsWith("Broken pipe") && !em.startsWith("Connection reset")) {
+ onFailure(volume, begin);
+ }
throw e;
}