This is an automated email from the ASF dual-hosted git repository. guoweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2bfb7c0a4413664f19203ee63fb2956d4847dd9c Author: Weijie Guo <[email protected]> AuthorDate: Mon Apr 1 17:37:52 2024 +0800 [hotfix] Document the field start from 1 for sortPartition --- .../apache/flink/streaming/api/datastream/PartitionWindowedStream.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java index 7741f3c27b3..744ad4e3734 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java @@ -77,7 +77,7 @@ public interface PartitionWindowedStream<T> { * KeyedPartitionWindowedStream}, the managed memory size can be set by * "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}. * - * @param field The field index on which records is sorted. + * @param field The field 1-based index on which records is sorted. * @param order The order in which records is sorted. * @return The data stream with sorted records. */
