You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/06/18 01:03:29 UTC
[pulsar] branch master updated: [pulsar-server] minor: fix typo in
service-config (#7248)
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 cb9a3a7 [pulsar-server] minor: fix typo in service-config (#7248)
cb9a3a7 is described below
commit cb9a3a7239bd477aae2b7e714f96f4ca28c8b1c1
Author: Rajan Dhabalia <rd...@apache.org>
AuthorDate: Wed Jun 17 18:03:17 2020 -0700
[pulsar-server] minor: fix typo in service-config (#7248)
Motivation
Minor: fix ; typo in config.
---
.../src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java | 2 +-
.../apache/pulsar/broker/service/persistent/PersistentSubscription.java | 2 +-
.../org/apache/pulsar/broker/service/persistent/PersistentTopic.java | 2 +-
.../java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java | 2 +-
.../src/test/java/org/apache/pulsar/client/impl/MessageIdTest.java | 2 +-
.../java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java | 2 +-
.../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java | 2 +-
.../pulsar/client/impl/RoundRobinPartitionMessageRouterImplTest.java | 2 +-
.../src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java | 2 +-
.../src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java | 2 +-
.../src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java | 2 +-
.../apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexTest.java | 2 +-
12 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
index fa9bed5..eb2d46a 100644
--- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
+++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
@@ -604,7 +604,7 @@ public class ServiceConfiguration implements PulsarConfiguration {
@FieldContext(
category = CATEGORY_SERVER,
doc = "Number of worker threads to serve non-persistent topic")
- private int numWorkerThreadsForNonPersistentTopic = Runtime.getRuntime().availableProcessors();;
+ private int numWorkerThreadsForNonPersistentTopic = Runtime.getRuntime().availableProcessors();
@FieldContext(
category = CATEGORY_SERVER,
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
index 8650226..e482aee 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java
@@ -145,7 +145,7 @@ public class PersistentSubscription implements Subscription {
this.cursor = cursor;
this.topicName = topic.getName();
this.subName = subscriptionName;
- this.fullName = MoreObjects.toStringHelper(this).add("topic", topicName).add("name", subName).toString();;
+ this.fullName = MoreObjects.toStringHelper(this).add("topic", topicName).add("name", subName).toString();
this.expiryMonitor = new PersistentMessageExpiryMonitor(topicName, subscriptionName, cursor);
this.setReplicated(replicated);
IS_FENCED_UPDATER.set(this, FALSE);
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 d7fcd41..581f2df 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
@@ -2152,7 +2152,7 @@ public class PersistentTopic extends AbstractTopic implements Topic, AddEntryCal
ctrl = replicatedSubscriptionsController.get();
}
- ctrl.receivedReplicatedSubscriptionMarker(position, markerType, payload);;
+ ctrl.receivedReplicatedSubscriptionMarker(position, markerType, payload);
}
Optional<ReplicatedSubscriptionsController> getReplicatedSubscriptionController() {
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
index 0c317a0..2632f51 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
@@ -93,7 +93,7 @@ public class BacklogQuotaManagerTest {
pulsar.start();
adminUrl = new URL("http://127.0.0.1" + ":" + pulsar.getListenPortHTTP().get());
- admin = PulsarAdmin.builder().serviceHttpUrl(adminUrl.toString()).build();;
+ admin = PulsarAdmin.builder().serviceHttpUrl(adminUrl.toString()).build();
admin.clusters().createCluster("usc", new ClusterData(adminUrl.toString()));
admin.tenants().createTenant("prop",
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageIdTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageIdTest.java
index 14349f7..e68e2bd 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageIdTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageIdTest.java
@@ -263,7 +263,7 @@ public class MessageIdTest extends BrokerTestBase {
Assert.assertEquals(messageIds.size(), 0, "Not all messages received successfully");
// TODO - this statement causes the broker to hang - need to look into
// it
- // consumer.unsubscribe();;
+ // consumer.unsubscribe();
}
/**
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
index c79b437..e966186 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -787,7 +787,7 @@ public class MultiTopicsConsumerImpl<T> extends ConsumerBase<T> {
subscribeFuture.completeExceptionally(
PulsarClientException.wrap(((Throwable) e).getCause(), String.format("Failed to subscribe %s with %d partitions", topicName, numPartitions)));
return null;
- });;
+ });
return consumer;
}
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
index 2d746f1..5ff8c3d 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
@@ -174,7 +174,7 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne
// default to use MessageCryptoBc;
MessageCrypto msgCryptoBc;
try {
- msgCryptoBc = new MessageCryptoBc(logCtx, true);;
+ msgCryptoBc = new MessageCryptoBc(logCtx, true);
} catch (Exception e) {
log.error("MessageCryptoBc may not included in the jar in Producer. e:", e);
msgCryptoBc = null;
diff --git a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/RoundRobinPartitionMessageRouterImplTest.java b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/RoundRobinPartitionMessageRouterImplTest.java
index 3cdebd7..6453b86 100644
--- a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/RoundRobinPartitionMessageRouterImplTest.java
+++ b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/RoundRobinPartitionMessageRouterImplTest.java
@@ -106,7 +106,7 @@ public class RoundRobinPartitionMessageRouterImplTest {
int idx = router.choosePartition(msg, new TopicMetadataImpl(5));
assertTrue(idx >= 0);
- assertTrue(idx < 5);;
+ assertTrue(idx < 5);
}
@Test
diff --git a/pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java b/pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java
index 57fecf9..484bdfb 100644
--- a/pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java
+++ b/pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java
@@ -105,7 +105,7 @@ public class RedisAbstractConfig implements Serializable {
}
public List<HostAndPort> getHostAndPorts() {
- List<HostAndPort> hostAndPorts = Lists.newArrayList();;
+ List<HostAndPort> hostAndPorts = Lists.newArrayList();
Preconditions.checkNotNull(redisHosts, "redisHosts property not set.");
String[] hosts = StringUtils.split(redisHosts, ",");
for (String host : hosts) {
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
index 61b027d..1e10dc7 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
@@ -368,7 +368,7 @@ public class PerformanceConsumer {
}
private static void printAggregatedThroughput(long start) {
- double elapsed = (System.nanoTime() - start) / 1e9;;
+ double elapsed = (System.nanoTime() - start) / 1e9;
double rate = totalMessagesReceived.sum() / elapsed;
double throughput = totalBytesReceived.sum() / elapsed * 8 / 1024 / 1024;
log.info(
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
index 9e9d0e8..1707787 100644
--- a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
+++ b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java
@@ -558,7 +558,7 @@ public class PerformanceProducer {
}
private static void printAggregatedThroughput(long start) {
- double elapsed = (System.nanoTime() - start) / 1e9;;
+ double elapsed = (System.nanoTime() - start) / 1e9;
double rate = totalMessagesSent.sum() / elapsed;
double throughput = totalBytesSent.sum() / elapsed / 1024 / 1024 * 8;
log.info(
diff --git a/tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexTest.java b/tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexTest.java
index e344c43..860f20d 100644
--- a/tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexTest.java
+++ b/tiered-storage/jcloud/src/test/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexTest.java
@@ -166,7 +166,7 @@ public class OffloadIndexTest {
OffloadIndexEntry e2 = OffloadIndexEntryImpl.of(wrapper.readLong(), wrapper.readInt(),
wrapper.readLong(), dataHeaderLength);
OffloadIndexEntry e3 = OffloadIndexEntryImpl.of(wrapper.readLong(), wrapper.readInt(),
- wrapper.readLong(), dataHeaderLength);;
+ wrapper.readLong(), dataHeaderLength);
assertEquals(e1.getEntryId(),entry1.getEntryId());
assertEquals(e1.getPartId(), entry1.getPartId());