From 80ad9367593c3a17bec12ef2a1baa927b867a71d Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Tue, 6 Mar 2018 18:04:05 +0000 Subject: [PATCH] minor javadoc fix in TimestampAssigner.java --- .../flink/streaming/api/functions/TimestampAssigner.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimestampAssigner.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimestampAssigner.java index 60debb966d07e..ba7bdd87e16c2 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimestampAssigner.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimestampAssigner.java @@ -40,9 +40,9 @@ public interface TimestampAssigner extends Function { * by ingestion time. If the element did not carry a timestamp before, this value is * {@code Long.MIN_VALUE}. * - * @param element The element that the timestamp is wil be assigned to. + * @param element The element that the timestamp will be assigned to. * @param previousElementTimestamp The previous internal timestamp of the element, - * or a negative value, if no timestamp has been assigned, yet. + * or a negative value, if no timestamp has been assigned yet. * @return The new timestamp. */ long extractTimestamp(T element, long previousElementTimestamp);