|
@@ -549,7 +549,8 @@ public class TestDataNodeHotSwapVolumes {
|
|
|
dn.data = Mockito.spy(data);
|
|
|
|
|
|
final int newVolumeCount = 40;
|
|
|
- List<Thread> addVolumeDelayedThreads = new ArrayList<>();
|
|
|
+ List<Thread> addVolumeDelayedThreads =
|
|
|
+ Collections.synchronizedList(new ArrayList<>());
|
|
|
AtomicBoolean addVolumeError = new AtomicBoolean(false);
|
|
|
AtomicBoolean listStorageError = new AtomicBoolean(false);
|
|
|
CountDownLatch addVolumeCompletionLatch =
|