[flink] branch release-1.7 updated: [hotfix] [table] Fix typos in Table javadoc.

[twalthr]

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

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


The following commit(s) were added to refs/heads/release-1.7 by this push:
     new b6ce4e4  [hotfix] [table] Fix typos in Table javadoc.
b6ce4e4 is described below

commit b6ce4e47b0e72befba72f2e1faa2c901876a2182
Author: EronWright <eronwri...@gmail.com>
AuthorDate: Mon Dec 31 09:02:17 2018 -0800

    [hotfix] [table] Fix typos in Table javadoc.
    
    This closes #7388.
---
 .../java/org/apache/flink/table/descriptors/ConnectorDescriptor.java | 2 +-
 .../apache/flink/table/descriptors/ConnectorDescriptorValidator.java | 5 +++++
 .../org/apache/flink/table/factories/BatchTableSinkFactory.scala     | 2 +-
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptor.java
 
b/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptor.java
index a1d3e78..ed62b46 100644
--- 
a/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptor.java
+++ 
b/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptor.java
@@ -68,7 +68,7 @@ public abstract class ConnectorDescriptor extends 
DescriptorBase implements Desc
 
        /**
         * Converts this descriptor into a set of connector properties. Usually 
prefixed with
-        * {@link FormatDescriptorValidator#FORMAT}.
+        * {@link ConnectorDescriptorValidator#CONNECTOR}.
         */
        protected abstract Map<String, String> toConnectorProperties();
 }
diff --git 
a/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptorValidator.java
 
b/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptorValidator.java
index 88cf349..cf9860a 100644
--- 
a/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptorValidator.java
+++ 
b/flink-libraries/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ConnectorDescriptorValidator.java
@@ -27,6 +27,11 @@ import org.apache.flink.annotation.Internal;
 public abstract class ConnectorDescriptorValidator implements 
DescriptorValidator {
 
        /**
+        * Prefix for connector-related properties.
+        */
+       public static final String CONNECTOR = "connector";
+
+       /**
         * Key for describing the type of the connector. Usually used for 
factory discovery.
         */
        public static final String CONNECTOR_TYPE = "connector.type";
diff --git 
a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/BatchTableSinkFactory.scala
 
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/BatchTableSinkFactory.scala
index 6fd1f7a..0b68523 100644
--- 
a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/BatchTableSinkFactory.scala
+++ 
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/BatchTableSinkFactory.scala
@@ -23,7 +23,7 @@ import java.util
 import org.apache.flink.table.sinks.BatchTableSink
 
 /**
-  * A factory to create configured table sink instances in a streaming 
environment based on
+  * A factory to create configured table sink instances in a batch environment 
based on
   * string-based properties. See also [[TableFactory]] for more information.
   *
   * @tparam T type of records that the factory consumes