This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit 08e7b1997b209d6f484fd753d66541759de55a38 Author: Ryan Skraba <r...@skraba.com> AuthorDate: Wed Sep 1 10:27:07 2021 +0200 [hotfix][docs]: Fix minor grammar and spelling mistakes docs: Incomplete sentence docs: use consistent voice chore: Connectors document review chore: Reword SplitEnumerator [hotfix][docs] Use consistent intro sentence Apply grammar fixes from code review Co-authored-by: Matthias Pohl <matthias.p...@aiven.io> --- .../connector/pulsar/source/enumerator/cursor/StartCursor.java | 4 ++-- .../flink/connector/pulsar/source/enumerator/cursor/StopCursor.java | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java index 9c1d699..eae7cbf 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java +++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java @@ -28,8 +28,8 @@ import org.apache.pulsar.client.api.SubscriptionType; import java.io.Serializable; /** - * A interface for users to specify the start position of a pulsar subscription. Since it would be - * serialized into split. The implementation for this interface should be well considered. I don't + * An interface for users to specify the start position of a pulsar subscription. Since it would be + * serialized into split, the implementation for this interface should be well considered. I don't * recommend adding extra internal state for this implementation. * * <p>This class would be used only for {@link SubscriptionType#Exclusive} and {@link diff --git a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java index d44c78f..866d036 100644 --- a/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java +++ b/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java @@ -33,9 +33,9 @@ import org.apache.pulsar.client.api.MessageId; import java.io.Serializable; /** - * A interface for users to specify the stop position of a pulsar subscription. Since it would be - * serialized into split. The implementation for this interface should be well considered. I don't - * recommend adding extra internal state for this implementation. + * An interface for users to specify the stop position of a pulsar subscription. Since it would be + * serialized into split, the implementation for this interface should be well considered. It's not + * recommended to add extra internal state for this implementation. */ @PublicEvolving @FunctionalInterface