This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new 76564b7  [FLINK-20156] Correct JavaDoc example code in 
WatermarkStrategy.withTimestampAssigner
76564b7 is described below

commit 76564b719167dbe1ac29899dcaaf873ebbce93dd
Author: Till Rohrmann <trohrm...@apache.org>
AuthorDate: Fri Nov 13 17:12:06 2020 +0100

    [FLINK-20156] Correct JavaDoc example code in 
WatermarkStrategy.withTimestampAssigner
    
    In order to compile with Java 8 we have to specify the generic parameter 
when
    chaining WatermarkStrategy.withTimestampAssigner.
    
    This closes #14069.
---
 .../java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java
 
b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java
index 8f0d158..65e243b 100644
--- 
a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java
+++ 
b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java
@@ -106,7 +106,7 @@ public interface WatermarkStrategy<T> extends
         *
         * <pre>
         * {@code WatermarkStrategy<CustomObject> wmStrategy = WatermarkStrategy
-        *   .forMonotonousTimestamps()
+        *   .<CustomObject>forMonotonousTimestamps()
         *   .withTimestampAssigner((event, timestamp) -> event.getTimestamp());
         * }</pre>
         */

Reply via email to