File tree 1 file changed +2
-2
lines changed
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/services
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 40
40
import org .slf4j .Logger ;
41
41
import org .slf4j .LoggerFactory ;
42
42
43
- import org .apache .commons .io .IOUtils ;
44
43
import org .apache .commons .lang3 .StringUtils ;
45
44
import org .apache .hadoop .fs .PathIOException ;
46
45
import org .apache .hadoop .fs .azurebfs .constants .FSOperationType ;
62
61
import static org .apache .hadoop .fs .azurebfs .constants .FileSystemConfigurations .STREAM_ID_LEN ;
63
62
import static org .apache .hadoop .fs .azurebfs .services .AbfsErrors .ERR_WRITE_WITHOUT_LEASE ;
64
63
import static org .apache .hadoop .fs .impl .StoreImplementationUtils .isProbeForSyncable ;
64
+ import static org .apache .hadoop .io .IOUtils .cleanupWithLogger ;
65
65
import static org .apache .hadoop .io .IOUtils .wrapException ;
66
66
import static org .apache .hadoop .fs .azurebfs .contracts .services .AppendRequestParameters .Mode .APPEND_MODE ;
67
67
import static org .apache .hadoop .fs .azurebfs .contracts .services .AppendRequestParameters .Mode .FLUSH_CLOSE_MODE ;
@@ -551,7 +551,7 @@ private void uploadBlockAsync(AbfsBlock blockToUpload,
551
551
outputStreamStatistics .uploadSuccessful (bytesLength );
552
552
return null ;
553
553
} finally {
554
- IOUtils . close ( blockUploadData , blockToUpload );
554
+ cleanupWithLogger ( LOG , blockUploadData , blockToUpload );
555
555
}
556
556
});
557
557
writeOperations .add (new WriteOperation (job , offset , bytesLength ));
You can’t perform that action at this time.
0 commit comments