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
