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

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 2c6441bbbe67f063b8d5c202b56e78083cb40eee
Author: stayhsfLee <[email protected]>
AuthorDate: Thu Aug 8 21:42:46 2019 +0800

    [hotfix][JavaDocs] Correct comment in KeyedStream
    
    This closes #9395
---
 .../java/org/apache/flink/streaming/api/datastream/KeyedStream.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
index 84df716..8c7937d 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
@@ -793,7 +793,7 @@ public class KeyedStream<T, KEY> extends DataStream<T> {
         * per key.
         *
         * @param positionToMax
-        *            The field position in the data points to minimize. This 
is applicable to
+        *            The field position in the data points to maximize. This 
is applicable to
         *            Tuple types, Scala case classes, and primitive types 
(which is considered
         *            as having one field).
         * @return The transformed DataStream.

Reply via email to