From 716b64ebb2224360d45c20c94efd0bb34f8210fe Mon Sep 17 00:00:00 2001 From: Sanjeev Kulkarni Date: Tue, 2 Jun 2020 16:18:15 -0700 Subject: [PATCH] Fix compilation issue due to conflicting changes --- .../broker/service/PrecisTopicPublishRateThrottleTest.java | 6 +++--- .../org/apache/pulsar/io/batch/BatchSourceExecutor.java | 2 +- 2 files changed, 4 insertions(+), 4 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() diff --git a/pulsar-io/batch/src/main/java/org/apache/pulsar/io/batch/BatchSourceExecutor.java b/pulsar-io/batch/src/main/java/org/apache/pulsar/io/batch/BatchSourceExecutor.java index 88a011e324bc6..e25128bf0353f 100644 --- a/pulsar-io/batch/src/main/java/org/apache/pulsar/io/batch/BatchSourceExecutor.java +++ b/pulsar-io/batch/src/main/java/org/apache/pulsar/io/batch/BatchSourceExecutor.java @@ -22,10 +22,10 @@ import lombok.extern.slf4j.Slf4j; import org.apache.pulsar.client.api.*; import org.apache.pulsar.common.io.BatchSourceConfig; +import org.apache.pulsar.common.util.Reflections; import org.apache.pulsar.functions.api.Record; import org.apache.pulsar.functions.utils.Actions; import org.apache.pulsar.functions.utils.FunctionCommon; -import org.apache.pulsar.functions.utils.Reflections; import org.apache.pulsar.functions.utils.SourceConfigUtils; import org.apache.pulsar.io.core.*;