This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to
refs/heads/spark-runner_structured-streaming by this push:
new f0f0138 Fixed Javadoc error
f0f0138 is described below
commit f0f01389dee96e93b0f9b8a86a78551b9d6bb828
Author: Alexey Romanenko <[email protected]>
AuthorDate: Fri Jan 25 11:16:37 2019 +0100
Fixed Javadoc error
---
.../runners/spark/structuredstreaming/translation/EncoderHelpers.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
index 90797c1..2912e3c 100644
---
a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
+++
b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
@@ -31,7 +31,7 @@ public class EncoderHelpers {
// the type inference mechanism to infer Encoder<WindowedValue<T>> to get
back the type checking
/**
- * Get a bytes {@link Encoder} for {@link WindowedValue<T>}. Bytes
serialisation is issued by Kryo
+ * Get a bytes {@link Encoder} for {@link WindowedValue}. Bytes
serialisation is issued by Kryo
*/
@SuppressWarnings("unchecked")
public static <T> Encoder<T> windowedValueEncoder() {
