@@ -1732,7 +1732,7 @@ private void renameDir(AzureBlobFileSystem currentFs, String producerQueueSize,
17321732 String consumerMaxLag , String maxThread , Path src , Path dst )
17331733 throws IOException {
17341734 Configuration config = createConfig (producerQueueSize , consumerMaxLag , maxThread );
1735- try (final AzureBlobFileSystem fs = (AzureBlobFileSystem ) FileSystem .newInstance (currentFs .getUri (), config )) {
1735+ try (AzureBlobFileSystem fs = (AzureBlobFileSystem ) FileSystem .newInstance (currentFs .getUri (), config )) {
17361736 fs .rename (src , dst );
17371737 validateRename (fs , src , dst , false , true , false );
17381738 }
@@ -1781,7 +1781,7 @@ private void validateRename(AzureBlobFileSystem fs, Path src, Path dst,
17811781 */
17821782 @ Test
17831783 public void testRenameDirWithDifferentParallelism () throws Exception {
1784- try (final AzureBlobFileSystem currentFs = getFileSystem ()) {
1784+ try (AzureBlobFileSystem currentFs = getFileSystem ()) {
17851785 assumeBlobServiceType ();
17861786 Path src = new Path ("/hbase/A1/A2" );
17871787 Path dst = new Path ("/hbase/A1/A3" );
@@ -1836,7 +1836,7 @@ private void createFiles(AzureBlobFileSystem fs, Path src, int numFiles)
18361836 */
18371837 @ Test
18381838 public void testRenameCopyFailureInBetween () throws Exception {
1839- try (final AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
1839+ try (AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
18401840 createConfig ("5" , "3" , "2" )))) {
18411841 assumeBlobServiceType ();
18421842 AbfsBlobClient client = (AbfsBlobClient ) addSpyHooksOnClient (fs );
@@ -1890,7 +1890,7 @@ public void testRenameCopyFailureInBetween() throws Exception {
18901890 */
18911891 @ Test
18921892 public void testRenameDeleteFailureInBetween () throws Exception {
1893- try (final AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
1893+ try (AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
18941894 createConfig ("5" , "3" , "2" )))) {
18951895 assumeBlobServiceType ();
18961896 AbfsBlobClient client = (AbfsBlobClient ) addSpyHooksOnClient (fs );
@@ -2506,7 +2506,7 @@ public void eTagChangedDuringRename() throws Exception {
25062506 fs .create (new Path (path , "file1.txt" ));
25072507 fs .create (new Path (path , "file2.txt" ));
25082508 AtomicInteger numberOfCopyBlobCalls = new AtomicInteger (0 );
2509- Mockito .doAnswer ( copyBlob -> {
2509+ Mockito .doAnswer (copyBlob -> {
25102510 numberOfCopyBlobCalls .incrementAndGet ();
25112511 return copyBlob .callRealMethod ();
25122512 })
@@ -2516,7 +2516,7 @@ public void eTagChangedDuringRename() throws Exception {
25162516 Mockito .any (TracingContext .class ));
25172517
25182518 AtomicInteger numberOfRedoRenameAtomicityCalls = new AtomicInteger (0 );
2519- Mockito .doAnswer ( redoRenameAtomicity -> {
2519+ Mockito .doAnswer (redoRenameAtomicity -> {
25202520 numberOfRedoRenameAtomicityCalls .incrementAndGet ();
25212521 return redoRenameAtomicity .callRealMethod ();
25222522 })
0 commit comments