@@ -1732,7 +1732,7 @@ private void renameDir(AzureBlobFileSystem currentFs, String producerQueueSize,
1732
1732
String consumerMaxLag , String maxThread , Path src , Path dst )
1733
1733
throws IOException {
1734
1734
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 )) {
1736
1736
fs .rename (src , dst );
1737
1737
validateRename (fs , src , dst , false , true , false );
1738
1738
}
@@ -1781,7 +1781,7 @@ private void validateRename(AzureBlobFileSystem fs, Path src, Path dst,
1781
1781
*/
1782
1782
@ Test
1783
1783
public void testRenameDirWithDifferentParallelism () throws Exception {
1784
- try (final AzureBlobFileSystem currentFs = getFileSystem ()) {
1784
+ try (AzureBlobFileSystem currentFs = getFileSystem ()) {
1785
1785
assumeBlobServiceType ();
1786
1786
Path src = new Path ("/hbase/A1/A2" );
1787
1787
Path dst = new Path ("/hbase/A1/A3" );
@@ -1836,7 +1836,7 @@ private void createFiles(AzureBlobFileSystem fs, Path src, int numFiles)
1836
1836
*/
1837
1837
@ Test
1838
1838
public void testRenameCopyFailureInBetween () throws Exception {
1839
- try (final AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
1839
+ try (AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
1840
1840
createConfig ("5" , "3" , "2" )))) {
1841
1841
assumeBlobServiceType ();
1842
1842
AbfsBlobClient client = (AbfsBlobClient ) addSpyHooksOnClient (fs );
@@ -1890,7 +1890,7 @@ public void testRenameCopyFailureInBetween() throws Exception {
1890
1890
*/
1891
1891
@ Test
1892
1892
public void testRenameDeleteFailureInBetween () throws Exception {
1893
- try (final AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
1893
+ try (AzureBlobFileSystem fs = Mockito .spy (this .getFileSystem (
1894
1894
createConfig ("5" , "3" , "2" )))) {
1895
1895
assumeBlobServiceType ();
1896
1896
AbfsBlobClient client = (AbfsBlobClient ) addSpyHooksOnClient (fs );
@@ -2506,7 +2506,7 @@ public void eTagChangedDuringRename() throws Exception {
2506
2506
fs .create (new Path (path , "file1.txt" ));
2507
2507
fs .create (new Path (path , "file2.txt" ));
2508
2508
AtomicInteger numberOfCopyBlobCalls = new AtomicInteger (0 );
2509
- Mockito .doAnswer ( copyBlob -> {
2509
+ Mockito .doAnswer (copyBlob -> {
2510
2510
numberOfCopyBlobCalls .incrementAndGet ();
2511
2511
return copyBlob .callRealMethod ();
2512
2512
})
@@ -2516,7 +2516,7 @@ public void eTagChangedDuringRename() throws Exception {
2516
2516
Mockito .any (TracingContext .class ));
2517
2517
2518
2518
AtomicInteger numberOfRedoRenameAtomicityCalls = new AtomicInteger (0 );
2519
- Mockito .doAnswer ( redoRenameAtomicity -> {
2519
+ Mockito .doAnswer (redoRenameAtomicity -> {
2520
2520
numberOfRedoRenameAtomicityCalls .incrementAndGet ();
2521
2521
return redoRenameAtomicity .callRealMethod ();
2522
2522
})
0 commit comments