This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new cef75fe [hotfix] [table] Fix typos in Table javadoc.
cef75fe is described below
commit cef75fe87f1c457a0ceda20a9ca40c54d354c914
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
