diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java index ce3d8d323685f..e02884f586fcf 100644 --- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java +++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java @@ -1267,7 +1267,7 @@ public CmdFunctions(Supplier admin) throws PulsarClientException { addCommand("restart", getRestarter()); addCommand("stop", getStopper()); addCommand("start", getStarter()); - // TODO depecreate getstatus + // TODO deprecate getstatus addCommand("status", getStatuser(), "getstatus"); addCommand("stats", getFunctionStats()); addCommand("list", getLister()); diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java index bd9cb503fd0c6..0a454154c1ff0 100644 --- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java +++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java @@ -93,7 +93,7 @@ public CmdSources(Supplier admin) { addCommand("update", updateSource); addCommand("delete", deleteSource); addCommand("get", getSource); - // TODO depecreate getstatus + // TODO deprecate getstatus addCommand("status", getSourceStatus, "getstatus"); addCommand("list", listSources); addCommand("stop", stopSource); diff --git a/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/LedgerUnderreplicationManagerTest.java b/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/LedgerUnderreplicationManagerTest.java index 205d617c4aca1..8784369246c10 100644 --- a/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/LedgerUnderreplicationManagerTest.java +++ b/pulsar-metadata/src/test/java/org/apache/pulsar/metadata/bookkeeper/LedgerUnderreplicationManagerTest.java @@ -616,7 +616,7 @@ public void testDisableLedgerReplication(String provider, Supplier urlSu AtomicInteger callbackCount = new AtomicInteger(); lum.notifyLedgerReplicationEnabled((rc, result) -> callbackCount.incrementAndGet()); lum.disableLedgerReplication(); - log.info("Disabled Ledeger Replication"); + log.info("Disabled Ledger Replication"); try { lum.markLedgerUnderreplicated(ledgerA, missingReplica); @@ -636,7 +636,7 @@ public void testDisableLedgerReplication(String provider, Supplier urlSu } /** - * Test enabling the ledger re-replication. After enableLedegerReplication, + * Test enabling the ledger re-replication. After enableLedgerReplication, * should continue getLedgerToRereplicate() task */ @Test(timeOut = 60000, dataProvider = "impl") @@ -657,7 +657,7 @@ public void testEnableLedgerReplication(String provider, Supplier urlSup lum.notifyLedgerReplicationEnabled((rc, result) -> callbackCount.incrementAndGet()); // disabling replication lum.disableLedgerReplication(); - log.debug("Disabled Ledeger Replication"); + log.debug("Disabled Ledger Replication"); String znodeA = getUrLedgerZnode(ledgerA); final CountDownLatch znodeLatch = new CountDownLatch(2); @@ -666,7 +666,7 @@ public void testEnableLedgerReplication(String provider, Supplier urlSup store.registerListener(n -> { if (n.getType() == NotificationType.Created && n.getPath().equals(urLockLedgerA)) { znodeLatch.countDown(); - log.debug("Recieved node creation event for the zNodePath:" + n.getPath()); + log.debug("Received node creation event for the zNodePath:" + n.getPath()); } }); @@ -688,7 +688,7 @@ public void testEnableLedgerReplication(String provider, Supplier urlSup lum.enableLedgerReplication(); znodeLatch.await(5, TimeUnit.SECONDS); - log.debug("Enabled Ledeger Replication"); + log.debug("Enabled Ledger Replication"); assertEquals(znodeLatch.getCount(), 0, "Failed to disable ledger replication!"); assertEquals(callbackCount.get(), 2, "Notify callback times mismatch"); } finally {