You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2019/08/26 11:22:32 UTC
[flink] 02/06: [hotfix][JavaDocs] Correct comment in KeyedStream
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 680c87cc557e2b71b654a79a3dd2050e41df7691
Author: stayhsfLee <yu...@gmail.com>
AuthorDate: Thu Aug 8 21:42:46 2019 +0800
[hotfix][JavaDocs] Correct comment in KeyedStream
This closes #9395
[ci skip]
---
.../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.