This is an automated email from the ASF dual-hosted git repository.
technoboy 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 2152870702b [fix][doc]Correcting spelling mistakes in the
pulsar-broker module (#20798)
2152870702b is described below
commit 2152870702bec5b91a3d7125aa539c4f8e71c943
Author: wangda <[email protected]>
AuthorDate: Fri Jul 14 11:47:54 2023 +0800
[fix][doc]Correcting spelling mistakes in the pulsar-broker module (#20798)
Signed-off-by: zhangwd3 <[email protected]>
---
.../broker/authentication/AuthenticationProviderAthenzTest.java | 2 +-
.../broker/loadbalance/extensions/scheduler/TransferShedder.java | 2 +-
.../java/org/apache/pulsar/broker/service/plugin/EntryFilter.java | 2 +-
.../apache/pulsar/broker/transaction/buffer/TransactionBuffer.java | 2 +-
.../buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java | 2 +-
.../src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java | 2 +-
.../java/org/apache/pulsar/broker/admin/v1/V1_AdminApi2Test.java | 2 +-
.../java/org/apache/pulsar/broker/service/BrokerServiceTest.java | 2 +-
.../org/apache/pulsar/broker/service/PersistentTopicE2ETest.java | 2 +-
.../java/org/apache/pulsar/broker/service/ResendRequestTest.java | 2 +-
.../pulsar/broker/service/persistent/DelayedDeliveryTest.java | 2 +-
.../org/apache/pulsar/broker/testcontext/PulsarTestContext.java | 2 +-
.../org/apache/pulsar/client/api/SimpleProducerConsumerTest.java | 4 ++--
.../org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java | 6 +++---
.../org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java | 2 +-
.../apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java | 2 +-
.../test/java/org/apache/pulsar/client/impl/PulsarTestClient.java | 2 +-
.../pulsar/client/impl/UnAcknowledgedMessagesTimeoutTest.java | 2 +-
.../org/apache/pulsar/stats/client/PulsarBrokerStatsClientTest.java | 2 +-
.../test/java/org/apache/pulsar/zookeeper/ZookeeperServerTest.java | 2 +-
20 files changed, 23 insertions(+), 23 deletions(-)
diff --git
a/pulsar-broker-auth-athenz/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderAthenzTest.java
b/pulsar-broker-auth-athenz/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderAthenzTest.java
index 89ee5ca0830..a5211c2f814 100644
---
a/pulsar-broker-auth-athenz/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderAthenzTest.java
+++
b/pulsar-broker-auth-athenz/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderAthenzTest.java
@@ -81,7 +81,7 @@ public class AuthenticationProviderAthenzTest {
sysPropProvider2.initialize(config);
assertEquals(sysPropProvider2.getAllowedOffset(), 0);
} catch (Exception e) {
- fail("Failed to get allowd offset from system property");
+ fail("Failed to get allowed offset from system property");
}
System.setProperty("pulsar.athenz.role.token_allowed_offset",
"invalid");
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java
index 7bb16bac124..cec052b65ff 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java
@@ -68,7 +68,7 @@ import org.slf4j.LoggerFactory;
/**
* Load shedding strategy that unloads bundles from the highest loaded brokers.
- * This strategy is only configurable in the broker load balancer extenstions
introduced by
+ * This strategy is only configurable in the broker load balancer extensions
introduced by
* PIP-192[https://github.com/apache/pulsar/issues/16691].
*
* This load shedding strategy has the following goals:
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilter.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilter.java
index 2e5a590fa19..686c72df8c2 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilter.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilter.java
@@ -49,7 +49,7 @@ public interface EntryFilter {
*/
REJECT,
/**
- * postpone message, it should not go to this conmumer.
+ * postpone message, it should not go to this consumer.
*/
RESCHEDULE
}
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java
index 99093e42fd7..9c32f762996 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java
@@ -141,7 +141,7 @@ public interface TransactionBuffer {
/**
* Close the buffer asynchronously.
* @param txnID {@link TxnID} txnId.
- * @param readPosition the persitent position of the txn message.
+ * @param readPosition the persistent position of the txn message.
* @return the txnId is aborted.
*/
boolean isTxnAborted(TxnID txnID, PositionImpl readPosition);
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
index fc92754d300..cd6c9c6123a 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java
@@ -175,7 +175,7 @@ public class SnapshotSegmentAbortedTxnProcessorImpl
implements AbortedTxnProcess
}
/**
- * Check werther the position in segmentIndex {@link
SnapshotSegmentAbortedTxnProcessorImpl#segmentIndex}
+ * Check whether the position in segmentIndex {@link
SnapshotSegmentAbortedTxnProcessorImpl#segmentIndex}
* is expired. If the position is not exist in the original topic, the
according transaction is an invalid
* transaction. And the according segment is invalid, too. The transaction
IDs before the transaction ID
* in the aborts are invalid, too.
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
index 8561ea68c16..7b047179ee4 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
@@ -479,7 +479,7 @@ public class AdminApiTest extends
MockedPulsarServiceBaseTest {
throw e;
}
- // validate regex: invlid regex for primary and seconday
+ // validate regex: invalid regex for primary and secondary
Map<String, String> parameters = new HashMap<>();
parameters.put("min_limit", "1");
parameters.put("usage_threshold", "100");
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApi2Test.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApi2Test.java
index cd08977a09b..38ccdf6f9c8 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApi2Test.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1_AdminApi2Test.java
@@ -451,7 +451,7 @@ public class V1_AdminApi2Test extends
MockedPulsarServiceBaseTest {
}
}
- // close consumer which will clean up intenral-receive-queue
+ // close consumer which will clean up internal-receive-queue
consumer.close();
// messages should still be available due to retention
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
index 9bc78de8337..3d67a4bc840 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerServiceTest.java
@@ -1242,7 +1242,7 @@ public class BrokerServiceTest extends BrokerTestBase {
BrokerService service = spy(pulsar.getBrokerService());
// create topic will fail to get managedLedgerConfig
CompletableFuture<ManagedLedgerConfig> failedManagedLedgerConfig = new
CompletableFuture<>();
- failedManagedLedgerConfig.completeExceptionally(new
NullPointerException("failed to peristent policy"));
+ failedManagedLedgerConfig.completeExceptionally(new
NullPointerException("failed to persistent policy"));
doReturn(failedManagedLedgerConfig).when(service).getManagedLedgerConfig(any());
CompletableFuture<Void> topicCreation = new CompletableFuture<Void>();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicE2ETest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicE2ETest.java
index 63f80911ae6..640cd2d37e3 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicE2ETest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PersistentTopicE2ETest.java
@@ -1499,7 +1499,7 @@ public class PersistentTopicE2ETest extends
BrokerTestBase {
}
Metrics metric = null;
- // sleep 1 sec to caclulate metrics per second
+ // sleep 1 sec to calculate metrics per second
Thread.sleep(1000);
brokerService.updateRates();
List<Metrics> metrics = brokerService.getTopicMetrics();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ResendRequestTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ResendRequestTest.java
index 113d766a8ab..ee58111ad77 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ResendRequestTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ResendRequestTest.java
@@ -147,7 +147,7 @@ public class ResendRequestTest extends BrokerTestBase {
assertEquals(messageDataHashSet.size(), totalMessages);
printIncomingMessageQueue(consumer);
- // 9. Calling resend after acking all messages - expectin 0 messages
+ // 9. Calling resend after acking all messages - expecting 0 messages
consumer.redeliverUnacknowledgedMessages();
assertNull(consumer.receive(2000, TimeUnit.MILLISECONDS));
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java
index 2db404ed90d..086d434b81d 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/DelayedDeliveryTest.java
@@ -233,7 +233,7 @@ public class DelayedDeliveryTest extends
ProducerConsumerBase {
.topic(topic)
.subscriptionName("shared-sub")
.subscriptionType(SubscriptionType.Shared)
- .receiverQueueSize(1) // Use small prefecthing to simulate the
multiple read batches
+ .receiverQueueSize(1) // Use small prefetching to simulate the
multiple read batches
.subscribe();
// Simulate race condition with high frequency of calls to
dispatcher.readMoreEntries()
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/testcontext/PulsarTestContext.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/testcontext/PulsarTestContext.java
index aac4c584579..f490ebd5ed2 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/testcontext/PulsarTestContext.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/testcontext/PulsarTestContext.java
@@ -83,7 +83,7 @@ import org.mockito.internal.util.MockUtil;
* There are few motivations for PulsarTestContext:
* <ul>
* <li>It reduces the reliance on Mockito for hooking into the PulsarService
for injecting mocks or customizing the behavior of some
- * collaborators. Mockito is not thread-safe and some mocking operations get
corrupted. Some examples of the issuess:
https://github.com/apache/pulsar/issues/13620,
https://github.com/apache/pulsar/issues/16444 and
https://github.com/apache/pulsar/issues/16427.</li>
+ * collaborators. Mockito is not thread-safe and some mocking operations get
corrupted. Some examples of the issues:
https://github.com/apache/pulsar/issues/13620,
https://github.com/apache/pulsar/issues/16444 and
https://github.com/apache/pulsar/issues/16427.</li>
* <li>Since the Mockito issue causes test flakiness, this change will improve
reliability.</li>
* <li>It makes it possible to use composition over inheritance in test
classes. This can help reduce the dependency on
* deep test base cases hierarchies.</li>
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
index 0c0e61fe33f..4536bda907b 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -2160,7 +2160,7 @@ public class SimpleProducerConsumerTest extends
ProducerConsumerBase {
/**
* It verifies that redelivery-of-specific messages: that redelivers all
those messages even when consumer gets
- * blocked due to unacked messsages
+ * blocked due to unacked messages
*
* Usecase: produce message with 10ms interval: so, consumer can consume
only 10 messages without acking
*
@@ -2239,7 +2239,7 @@ public class SimpleProducerConsumerTest extends
ProducerConsumerBase {
/**
* It verifies that redelivery-of-specific messages: that redelivers all
those messages even when consumer gets
- * blocked due to unacked messsages
+ * blocked due to unacked messages
*
* Usecase: Consumer starts consuming only after all messages have been
produced. So, consumer consumes total
* receiver-queue-size number messages => ask for redelivery and receives
all messages again.
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
index e126d963a88..d3cb1d60d37 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1_ProducerConsumerTest.java
@@ -951,7 +951,7 @@ public class V1_ProducerConsumerTest extends
V1_ProducerConsumerBase {
/**
* Verify: Consumer stops receiving msg when reach unack-msg limit and
starts receiving once acks messages 1.
* Produce X (600) messages 2. Consumer has receive size (10) and receive
message without acknowledging 3. Consumer
- * will stop receiving message after unAckThreshold = 500 4. Consumer acks
messages and starts consuming remanining
+ * will stop receiving message after unAckThreshold = 500 4. Consumer acks
messages and starts consuming remaining
* messages This testcase enables checksum sending while producing message
and broker verifies the checksum for the
* message.
*
@@ -1574,7 +1574,7 @@ public class V1_ProducerConsumerTest extends
V1_ProducerConsumerBase {
/**
* It verifies that redelivery-of-specific messages: that redelivers all
those messages even when consumer gets
- * blocked due to unacked messsages
+ * blocked due to unacked messages
*
* Usecase: produce message with 10ms interval: so, consumer can consume
only 10 messages without acking
*
@@ -1659,7 +1659,7 @@ public class V1_ProducerConsumerTest extends
V1_ProducerConsumerBase {
/**
* It verifies that redelivery-of-specific messages: that redelivers all
those messages even when consumer gets
- * blocked due to unacked messsages
+ * blocked due to unacked messages
*
* Usecase: Consumer starts consuming only after all messages have been
produced. So, consumer consumes total
* receiver-queue-size number messages => ask for redelivery and receives
all messages again.
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
index 716dd1019f4..095fd358cf3 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/BrokerClientIntegrationTest.java
@@ -591,7 +591,7 @@ public class BrokerClientIntegrationTest extends
ProducerConsumerBase {
}
/**
- * It verifies that client closes the connection on internalSerevrError
which is "ServiceNotReady" from Broker-side
+ * It verifies that client closes the connection on internalServerError
which is "ServiceNotReady" from Broker-side
*
* @throws Exception
*/
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java
index 09a9a003f3e..572a33e871d 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplTest.java
@@ -514,7 +514,7 @@ public class PatternTopicsConsumerImplTest extends
ProducerConsumerBase {
admin.topics().createPartitionedTopic(topicName2, 2);
admin.topics().createPartitionedTopic(topicName3, 3);
- // 2. Create consumer, this should success, but with empty
sub-consumser internal
+ // 2. Create consumer, this should success, but with empty
sub-consumer internal
Consumer<byte[]> consumer = pulsarClient.newConsumer()
.topicsPattern(pattern)
.patternAutoDiscoveryPeriod(2)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarTestClient.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarTestClient.java
index 0ba8511c0ca..a725562ac40 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarTestClient.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarTestClient.java
@@ -127,7 +127,7 @@ public class PulsarTestClient extends PulsarClientImpl {
}
/**
- * Overrides the producer instance with an anonynomous subclass that adds
hooks for observing new
+ * Overrides the producer instance with an anonymous subclass that adds
hooks for observing new
* OpSendMsg instances being added to pending messages in the client.
* It also configures the hook to drop OpSend messages when dropping is
enabled.
*/
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/UnAcknowledgedMessagesTimeoutTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/UnAcknowledgedMessagesTimeoutTest.java
index 34e4f6a4d6d..a0497b294c9 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/UnAcknowledgedMessagesTimeoutTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/UnAcknowledgedMessagesTimeoutTest.java
@@ -185,7 +185,7 @@ public class UnAcknowledgedMessagesTimeoutTest extends
BrokerTestBase {
}
long size = ((ConsumerImpl<?>)
consumer).getUnAckedMessageTracker().size();
assertEquals(size, totalMessages);
- log.info("Comulative Ack sent for " + new
String(lastMessage.getData()));
+ log.info("Cumulative Ack sent for " + new
String(lastMessage.getData()));
log.info("Message ID details " +
lastMessage.getMessageId().toString());
consumer.acknowledgeCumulative(lastMessage);
size = ((ConsumerImpl<?>) consumer).getUnAckedMessageTracker().size();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/stats/client/PulsarBrokerStatsClientTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/stats/client/PulsarBrokerStatsClientTest.java
index b58ed1e40ba..824646a8aea 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/stats/client/PulsarBrokerStatsClientTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/stats/client/PulsarBrokerStatsClientTest.java
@@ -126,7 +126,7 @@ public class PulsarBrokerStatsClientTest extends
ProducerConsumerBase {
PersistentTopicInternalStats internalStats =
topic.getInternalStats(true).get();
assertNotNull(internalStats.ledgers.get(0).metadata);
// For the mock test, the default ensembles is
["192.0.2.1:1234","192.0.2.2:1234","192.0.2.3:1234"]
- // The registed bookie ID is 192.168.1.1:5000
+ // The registered bookie ID is 192.168.1.1:5000
assertTrue(internalStats.ledgers.get(0).underReplicated);
CursorStats cursor = internalStats.cursors.get(subscriptionName);
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/zookeeper/ZookeeperServerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/zookeeper/ZookeeperServerTest.java
index 013bc23d663..eec61b9144e 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/zookeeper/ZookeeperServerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/zookeeper/ZookeeperServerTest.java
@@ -70,7 +70,7 @@ public class ZookeeperServerTest implements Closeable {
public void stop() throws IOException {
zks.shutdown();
serverFactory.shutdown();
- log.info("Stoppend ZK server at {}", hostPort);
+ log.info("Stopped ZK server at {}", hostPort);
}
@Override
