[flink] 05/05: [hotfix][table-common] Fix typos in docs of new source/sink interfaces

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 7655fcd9fbc1126d251a33c8fb69e86b628ddea9
Author: Timo Walther <tw...@apache.org>
AuthorDate: Mon Jun 22 17:20:39 2020 +0200

    [hotfix][table-common] Fix typos in docs of new source/sink interfaces
---
 .../java/org/apache/flink/table/connector/sink/DynamicTableSink.java  | 2 +-
 .../org/apache/flink/table/connector/source/LookupTableSource.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java
index 6e33371..3a1c857 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java
@@ -41,7 +41,7 @@ import java.io.Serializable;
  * <p>Dynamic tables are the core concept of Flink's Table & SQL API for processing both bounded and
  * unbounded data in a unified fashion. By definition, a dynamic table can change over time.
  *
- * <p>When writing a dynamic table, the content can either be considered as a changelog (finite or
+ * <p>When writing a dynamic table, the content can always be considered as a changelog (finite or
  * infinite) for which all changes are written out continuously until the changelog is exhausted. The
  * given {@link ChangelogMode} indicates the set of changes that the sink accepts during runtime.
  *
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java
index 363873e..e0b17d5 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/LookupTableSource.java
@@ -27,8 +27,8 @@ import java.io.Serializable;
  * A {@link DynamicTableSource} that looks up rows of an external storage system by one or more keys
  * during runtime.
  *
- * <p>Compared to {@link ScanTableSource}, the source must not read the entire table and can lazily fetch
- * individual values from a (possibly continuously changing) external table when necessary.
+ * <p>Compared to {@link ScanTableSource}, the source does not have to read the entire table and can
+ * lazily fetch individual values from a (possibly continuously changing) external table when necessary.
  *
  * <p>Note: Compared to {@link ScanTableSource}, a {@link LookupTableSource} does only support emitting
  * insert-only changes currently (see also {@link RowKind}). Further abilities are not supported.