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 <aromanenko....@gmail.com> 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() {