From e825aa2f5e0c5a06073bac2307912a8333d17256 Mon Sep 17 00:00:00 2001 From: rdhabalia Date: Tue, 2 Jun 2020 13:20:12 -0700 Subject: [PATCH] Fix: typo and compilation error --- .../broker/service/PrecisTopicPublishRateThrottleTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java index c7a02aa812615..31130fafe9fa1 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java @@ -45,7 +45,7 @@ public void testPrecisTopicPublishRateLimitingDisabled() throws Exception { PublishRate publishRate = new PublishRate(1,10); // disable precis topic publish rate limiting conf.setPreciseTopicPublishRateLimiterEnable(false); - conf.setMaxPendingPublishdRequestsPerConnection(0); + conf.setMaxPendingPublishRequestsPerConnection(0); super.baseSetup(); final String topic = "persistent://prop/ns-abc/testPrecisTopicPublishRateLimiting"; org.apache.pulsar.client.api.Producer producer = pulsarClient.newProducer() @@ -84,7 +84,7 @@ public void testPrecisTopicPublishRateLimitingDisabled() throws Exception { public void testProducerBlockedByPrecisTopicPublishRateLimiting() throws Exception { PublishRate publishRate = new PublishRate(1,10); conf.setPreciseTopicPublishRateLimiterEnable(true); - conf.setMaxPendingPublishdRequestsPerConnection(0); + conf.setMaxPendingPublishRequestsPerConnection(0); super.baseSetup(); final String topic = "persistent://prop/ns-abc/testPrecisTopicPublishRateLimiting"; org.apache.pulsar.client.api.Producer producer = pulsarClient.newProducer() @@ -116,7 +116,7 @@ public void testProducerBlockedByPrecisTopicPublishRateLimiting() throws Excepti public void testPrecisTopicPublishRateLimitingProduceRefresh() throws Exception { PublishRate publishRate = new PublishRate(1,10); conf.setPreciseTopicPublishRateLimiterEnable(true); - conf.setMaxPendingPublishdRequestsPerConnection(0); + conf.setMaxPendingPublishRequestsPerConnection(0); super.baseSetup(); final String topic = "persistent://prop/ns-abc/testPrecisTopicPublishRateLimiting"; org.apache.pulsar.client.api.Producer producer = pulsarClient.newProducer()