|
@@ -40,7 +40,6 @@ import org.apache.hadoop.thirdparty.com.google.common.util.concurrent.MoreExecut
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
-import org.apache.commons.io.IOUtils;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.apache.hadoop.fs.PathIOException;
|
|
|
import org.apache.hadoop.fs.azurebfs.constants.FSOperationType;
|
|
@@ -62,6 +61,7 @@ import static org.apache.hadoop.fs.azurebfs.constants.AbfsHttpConstants.APPEND_A
|
|
|
import static org.apache.hadoop.fs.azurebfs.constants.FileSystemConfigurations.STREAM_ID_LEN;
|
|
|
import static org.apache.hadoop.fs.azurebfs.services.AbfsErrors.ERR_WRITE_WITHOUT_LEASE;
|
|
|
import static org.apache.hadoop.fs.impl.StoreImplementationUtils.isProbeForSyncable;
|
|
|
+import static org.apache.hadoop.io.IOUtils.cleanupWithLogger;
|
|
|
import static org.apache.hadoop.io.IOUtils.wrapException;
|
|
|
import static org.apache.hadoop.fs.azurebfs.contracts.services.AppendRequestParameters.Mode.APPEND_MODE;
|
|
|
import static org.apache.hadoop.fs.azurebfs.contracts.services.AppendRequestParameters.Mode.FLUSH_CLOSE_MODE;
|
|
@@ -551,7 +551,7 @@ public class AbfsOutputStream extends OutputStream implements Syncable,
|
|
|
outputStreamStatistics.uploadSuccessful(bytesLength);
|
|
|
return null;
|
|
|
} finally {
|
|
|
- IOUtils.close(blockUploadData, blockToUpload);
|
|
|
+ cleanupWithLogger(LOG, blockUploadData, blockToUpload);
|
|
|
}
|
|
|
});
|
|
|
writeOperations.add(new WriteOperation(job, offset, bytesLength));
|