commit | 3893e32574575c98c50b8b6a2ccc5aa7fdc3e4f6 | [log] [tgz] |
---|---|---|
author | Frank J Kelly <kellyfj@gmail.com> | Tue Sep 29 23:35:32 2020 -0400 |
committer | GitHub <noreply@github.com> | Wed Sep 30 11:35:32 2020 +0800 |
tree | c21b861c2515ea455c7f03dae27374abbaed2f2d | |
parent | 22e1978458908ee28dd2e6bf6d3e3af8ff894bb5 [diff] |
Fix JavaDoc issues. Spotted by IntelliJ (#8054) Issues spotted by IntelliJ ### Motivation IntelliJ complains and highlights these issues ### Modifications Sync JavaDoc with code ### Verifying this change This change is a trivial rework / code cleanup without any test coverage.
diff --git a/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConfiguration.java b/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConfiguration.java index 0ef7686..db797ee 100644 --- a/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConfiguration.java +++ b/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConfiguration.java
@@ -174,7 +174,7 @@ * if subscription is not durable then it creates non-durable reader to start reading from the * {@link #setNonDurableSubscriptionReadPosition(MessagePosition)} in topic. * - * @param nonDurableSubscription + * @param durableSubscription */ public void setDurableSubscription(boolean durableSubscription) { this.durableSubscription = durableSubscription;
diff --git a/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConsumer.java b/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConsumer.java index d845c4e..5502a62 100644 --- a/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConsumer.java +++ b/pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConsumer.java
@@ -29,7 +29,7 @@ * Receives a single message. * * @param waitTime - * @param milliseconds + * @param unit * @return * @throws PulsarClientException */
diff --git a/pulsar-storm/src/main/java/org/apache/pulsar/storm/SharedPulsarClient.java b/pulsar-storm/src/main/java/org/apache/pulsar/storm/SharedPulsarClient.java index b8263a4..f4950c6 100644 --- a/pulsar-storm/src/main/java/org/apache/pulsar/storm/SharedPulsarClient.java +++ b/pulsar-storm/src/main/java/org/apache/pulsar/storm/SharedPulsarClient.java
@@ -60,7 +60,6 @@ * * @param componentId * the id of the spout/bolt - * @param serviceUrl * @param clientConf * @return * @throws PulsarClientException