@@ -232,13 +232,13 @@ private FSDataInputStream open(final Path path,
232
232
* {@link org.apache.hadoop.fs.impl.OpenFileParameters}. Ensure that
233
233
* FileStatus entered is up-to-date, as it will be used to create the
234
234
* InputStream (with info such as contentLength, eTag)
235
- * @param path The location of file to be opened
235
+ * @param path The location of file to be opened
236
236
* @param parameters OpenFileParameters instance; can hold FileStatus,
237
237
* Configuration, bufferSize and mandatoryKeys
238
238
*/
239
239
@ Override
240
240
protected CompletableFuture <FSDataInputStream > openFileWithOptions (
241
- final Path path , final OpenFileParameters parameters ) {
241
+ final Path path , final OpenFileParameters parameters ) throws IOException {
242
242
LOG .debug ("AzureBlobFileSystem.openFileWithOptions path: {}" , path );
243
243
AbstractFSBuilderImpl .rejectUnknownMandatoryKeys (
244
244
parameters .getMandatoryKeys (),
@@ -253,8 +253,7 @@ protected CompletableFuture<FSDataInputStream> openFileWithOptions(
253
253
public FSDataOutputStream create (final Path f , final FsPermission permission ,
254
254
final boolean overwrite , final int bufferSize , final short replication ,
255
255
final long blockSize , final Progressable progress ) throws IOException {
256
- LOG .debug (
257
- "AzureBlobFileSystem.create path: {} permission: {} overwrite: {} bufferSize: {}" ,
256
+ LOG .debug ("AzureBlobFileSystem.create path: {} permission: {} overwrite: {} bufferSize: {}" ,
258
257
f ,
259
258
permission ,
260
259
overwrite ,
@@ -273,7 +272,7 @@ public FSDataOutputStream create(final Path f, final FsPermission permission,
273
272
FsPermission .getUMask (getConf ()), tracingContext );
274
273
statIncrement (FILES_CREATED );
275
274
return new FSDataOutputStream (outputStream , statistics );
276
- } catch (AzureBlobFileSystemException ex ) {
275
+ } catch (AzureBlobFileSystemException ex ) {
277
276
checkException (f , ex );
278
277
return null ;
279
278
}
@@ -328,7 +327,8 @@ public FSDataOutputStream createNonRecursive(final Path f,
328
327
329
328
@ Override
330
329
public FSDataOutputStream append (final Path f , final int bufferSize , final Progressable progress ) throws IOException {
331
- LOG .debug ("AzureBlobFileSystem.append path: {} bufferSize: {}" ,
330
+ LOG .debug (
331
+ "AzureBlobFileSystem.append path: {} bufferSize: {}" ,
332
332
f .toString (),
333
333
bufferSize );
334
334
statIncrement (CALL_APPEND );
@@ -364,7 +364,7 @@ public boolean rename(final Path src, final Path dst) throws IOException {
364
364
fileSystemId , FSOperationType .RENAME , true , tracingHeaderFormat ,
365
365
listener );
366
366
// rename under same folder;
367
- if (makeQualified (parentFolder ).equals (qualifiedDstPath )) {
367
+ if (makeQualified (parentFolder ).equals (qualifiedDstPath )) {
368
368
return tryGetFileStatus (qualifiedSrcPath , tracingContext ) != null ;
369
369
}
370
370
@@ -403,7 +403,10 @@ public boolean rename(final Path src, final Path dst) throws IOException {
403
403
return true ;
404
404
} catch (AzureBlobFileSystemException ex ) {
405
405
LOG .debug ("Rename operation failed. " , ex );
406
- checkException (src , ex , AzureServiceErrorCode .PATH_ALREADY_EXISTS ,
406
+ checkException (
407
+ src ,
408
+ ex ,
409
+ AzureServiceErrorCode .PATH_ALREADY_EXISTS ,
407
410
AzureServiceErrorCode .INVALID_RENAME_SOURCE_PATH ,
408
411
AzureServiceErrorCode .SOURCE_PATH_NOT_FOUND , AzureServiceErrorCode .INVALID_SOURCE_OR_DESTINATION_RESOURCE_TYPE ,
409
412
AzureServiceErrorCode .RENAME_DESTINATION_PARENT_PATH_NOT_FOUND ,
0 commit comments