Reviewed-by: He Xiaoqiao <hexiaoqiao@apache.org>
@@ -279,7 +279,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;
}