[pulsar] branch master updated: Fix some typos in PersistentTopic.java (#14416)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 26b6656  Fix some typos in PersistentTopic.java (#14416)
26b6656 is described below

commit 26b6656ae0d52257d2fecb955ca8b7209486a735
Author: lixinyang <84...@users.noreply.github.com>
AuthorDate: Mon Feb 28 17:04:18 2022 +0800

    Fix some typos in PersistentTopic.java (#14416)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 320f0f8..5f5d7cb 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -515,7 +515,6 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
             // If the managed ledger has been fenced, we cannot continue using it. We need to close and reopen
             close();
         } else {
-
             // fence topic when failed to write a message to BK
             fence();
             // close all producers
@@ -1668,10 +1667,9 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
             try {
                 ((PersistentReplicator) replicator).updateCursorState();
             } catch (Exception e) {
-                log.warn("[{}] Failed to update cursro state ", topic, e);
+                log.warn("[{}] Failed to update cursor state ", topic, e);
             }
 
-
             // Update replicator stats
             ReplicatorStatsImpl rStat = replicator.getStats();