ZOOKEEPER-4924: Fix double "the" word typos (#2251)

zookeeper-server/src/main/java/org/apache/zookeeper/server/embedded/ZooKeeperServerEmbeddedImpl.java

@@ -116,7 +116,7 @@ class ZooKeeperServerEmbeddedImpl implements ZooKeeperServerEmbedded {
                 }
             };
 
-            // Start and schedule the the purge task
+            // Start and schedule the purge task
             purgeMgr = new DatadirCleanupManager(config
                     .getDataDir(), config.getDataLogDir(), config
                     .getSnapRetainCount(), config.getPurgeIntervalInMs());

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumPeer.java

@@ -1570,7 +1570,7 @@ public class QuorumPeer extends ZooKeeperThread implements QuorumStats.Provider
                             LOG.warn("Unexpected exception", e);
                             setPeerState(ServerState.LOOKING);
                         } finally {
-                            // If the thread is in the the grace period, interrupt
+                            // If the thread is in the grace period, interrupt
                             // to come out of waiting.
                             roZkMgr.interrupt();
                             roZk.shutdown();

zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumPeerMain.java

@@ -125,7 +125,7 @@ public class QuorumPeerMain {
             config.parse(args[0]);
         }
 
-        // Start and schedule the the purge task
+        // Start and schedule the purge task
         DatadirCleanupManager purgeMgr = new DatadirCleanupManager(
             config.getDataDir(),
             config.getDataLogDir(),

zookeeper-server/src/test/java/org/apache/zookeeper/server/ZxidRolloverTest.java

@@ -192,7 +192,7 @@ public class ZxidRolloverTest extends ZKTestCase {
         assertTrue(ClientBase.waitForServerDown("127.0.0.1:" + peer.clientPort, ClientBase.CONNECTION_TIMEOUT),
                 "Waiting for server down");
 
-        // if idx is the the leader then everyone will get disconnected,
+        // if idx is the leader then everyone will get disconnected,
         // otherwise if idx is a follower then just that client will get
         // disconnected
         if (idx == idxLeader) {

zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/WatchLeakTest.java

@@ -128,7 +128,7 @@ public class WatchLeakTest {
             // OK, now the follower knows that the session is valid or invalid, let's try
             // to send the watches
             nioCnxn.doIO(sk);
-            // wait for the the request processor to do his job
+            // wait for the request processor to do his job
             Thread.sleep(1000L);
             LOG.info("Watches processed");
             // If session has not been validated, there must be NO watches

zookeeper-server/src/test/java/org/apache/zookeeper/test/ClientPortBindTest.java

@@ -84,7 +84,7 @@ public class ClientPortBindTest extends ZKTestCase {
 
         ServerCnxnFactory f = ServerCnxnFactory.createFactory(new InetSocketAddress(bindAddress, PORT), -1);
         f.startup(zks);
-        LOG.info("starting up the the server, waiting");
+        LOG.info("starting up the server, waiting");
 
         assertTrue(ClientBase.waitForServerUp(HOSTPORT, CONNECTION_TIMEOUT), "waiting for server up");
         ZooKeeper zk = ClientBase.createZKClient(HOSTPORT);

zookeeper-server/src/test/java/org/apache/zookeeper/test/RecoveryTest.java

@@ -73,7 +73,7 @@ public class RecoveryTest extends ZKTestCase implements Watcher {
             final int PORT = Integer.parseInt(HOSTPORT.split(":")[1]);
             ServerCnxnFactory f = ServerCnxnFactory.createFactory(PORT, -1);
             f.startup(zks);
-            LOG.info("starting up the the server, waiting");
+            LOG.info("starting up the server, waiting");
 
             assertTrue(ClientBase.waitForServerUp(HOSTPORT, CONNECTION_TIMEOUT), "waiting for server up");