This is an automated email from the ASF dual-hosted git repository.
chesnay 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 b3392c4 [hotfix][javadocs] Fix reference in
KeyedSerializationSchemaWrapper
b3392c4 is described below
commit b3392c49aa1f83288c3f16370e7d69cbaf5ae0b7
Author: Mai Nakagawa <mai.nakag...@thinkbiganalytics.com>
AuthorDate: Thu Nov 15 22:17:48 2018 +0900
[hotfix][javadocs] Fix reference in KeyedSerializationSchemaWrapper
---
.../streaming/util/serialization/KeyedSerializationSchemaWrapper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchemaWrapper.java
b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchemaWrapper.java
index 013ea62..5f3d232 100644
---
a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchemaWrapper.java
+++
b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchemaWrapper.java
@@ -21,7 +21,7 @@ import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.serialization.SerializationSchema;
/**
- * A simple wrapper for using the SerializationSchema with the
KeyedDeserializationSchema
+ * A simple wrapper for using the SerializationSchema with the
KeyedSerializationSchema
* interface.
* @param <T> The type to serialize
*/
