1 files changed, 7 insertions, 7 deletions
diff --git a/zookeeper-server/src/test/java/org/apache/zookeeper/server/watch/WatchManagerTest.java b/zookeeper-server/src/test/java/org/apache/zookeeper/server/watch/WatchManagerTest.java
index bd613a444..f65391c49 100644
--- a/zookeeper-server/src/test/java/org/apache/zookeeper/server/watch/WatchManagerTest.java
+++ b/zookeeper-server/src/test/java/org/apache/zookeeper/server/watch/WatchManagerTest.java
@@ -236,7 +236,7 @@ public class WatchManagerTest extends ZKTestCase {
         // 1. start 5 workers to trigger watchers on that path
         //    count all the watchers have been fired
         AtomicInteger watchTriggered = new AtomicInteger();
-        List<WatcherTriggerWorker> triggerWorkers = new ArrayList<WatcherTriggerWorker>();
+        List<WatcherTriggerWorker> triggerWorkers = new ArrayList<>();
         for (int i = 0; i < 5; i++) {
             WatcherTriggerWorker worker = new WatcherTriggerWorker(manager, paths, watchTriggered);
             triggerWorkers.add(worker);
@@ -246,7 +246,7 @@ public class WatchManagerTest extends ZKTestCase {
         // 2. start 5 workers to add different watchers on the same path
         //    count all the watchers being added
         AtomicInteger watchesAdded = new AtomicInteger();
-        List<AddWatcherWorker> addWorkers = new ArrayList<AddWatcherWorker>();
+        List<AddWatcherWorker> addWorkers = new ArrayList<>();
         for (int i = 0; i < 5; i++) {
             AddWatcherWorker worker = new AddWatcherWorker(manager, paths, watchers, watchesAdded);
             addWorkers.add(worker);
@@ -297,7 +297,7 @@ public class WatchManagerTest extends ZKTestCase {
         // 1. start 5 workers to remove watchers on those path
         //    record the watchers have been removed
         AtomicInteger watchesRemoved = new AtomicInteger();
-        List<RemoveWatcherWorker> removeWorkers = new ArrayList<RemoveWatcherWorker>();
+        List<RemoveWatcherWorker> removeWorkers = new ArrayList<>();
         for (int i = 0; i < 5; i++) {
             RemoveWatcherWorker worker = new RemoveWatcherWorker(manager, paths, watchers, watchesRemoved);
             removeWorkers.add(worker);
@@ -307,7 +307,7 @@ public class WatchManagerTest extends ZKTestCase {
         // 2. start 5 workers to add different watchers on different path
         //    record the watchers have been added
         AtomicInteger watchesAdded = new AtomicInteger();
-        List<AddWatcherWorker> addWorkers = new ArrayList<AddWatcherWorker>();
+        List<AddWatcherWorker> addWorkers = new ArrayList<>();
         for (int i = 0; i < 5; i++) {
             AddWatcherWorker worker = new AddWatcherWorker(manager, paths, watchers, watchesAdded);
             addWorkers.add(worker);
@@ -359,8 +359,8 @@ public class WatchManagerTest extends ZKTestCase {
 
         // 1. start 5 workers to randomly mark those watcher as dead
         //    and remove them from watch manager
-        Set<Watcher> deadWatchers = new HashSet<Watcher>();
-        List<CreateDeadWatchersWorker> deadWorkers = new ArrayList<CreateDeadWatchersWorker>();
+        Set<Watcher> deadWatchers = new HashSet<>();
+        List<CreateDeadWatchersWorker> deadWorkers = new ArrayList<>();
         for (int i = 0; i < 5; i++) {
             CreateDeadWatchersWorker worker = new CreateDeadWatchersWorker(manager, watchers, deadWatchers);
             deadWorkers.add(worker);
@@ -369,7 +369,7 @@ public class WatchManagerTest extends ZKTestCase {
 
         // 2. start 5 workers to add different watchers on the same path
         AtomicInteger watchesAdded = new AtomicInteger();
-        List<AddWatcherWorker> addWorkers = new ArrayList<AddWatcherWorker>();
+        List<AddWatcherWorker> addWorkers = new ArrayList<>();
         for (int i = 0; i < 5; i++) {
             AddWatcherWorker worker = new AddWatcherWorker(manager, paths, watchers, watchesAdded);
             addWorkers.add(worker);