From 2bfb7c0a4413664f19203ee63fb2956d4847dd9c Mon Sep 17 00:00:00 2001 From: Weijie Guo Date: Mon, 1 Apr 2024 17:37:52 +0800 Subject: [PATCH] [hotfix] Document the field start from 1 for sortPartition --- .../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 7741f3c27b309..744ad4e373442 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 @@ SingleOutputStreamOperator aggregate( * 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. */