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 32ab253a0442076659b0de67cecd525de47138c4 Author: Weijie Guo <[email protected]> AuthorDate: Mon Apr 1 17:55:10 2024 +0800 [hotfix] Correct the option key for sortPartition --- .../api/datastream/PartitionWindowedStream.java | 21 +++++++++------------ 1 file changed, 9 insertions(+), 12 deletions(-) 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 744ad4e3734..e73f39dde33 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 @@ -72,10 +72,9 @@ public interface PartitionWindowedStream<T> { * records must be {@link Tuple}. * * <p>This operator will use managed memory for the sort.For {@link - * NonKeyedPartitionWindowedStream}, the managed memory size can be set by - * "execution.sort.partition.memory" in {@link ExecutionOptions}. For {@link - * KeyedPartitionWindowedStream}, the managed memory size can be set by - * "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}. + * NonKeyedPartitionWindowedStream}, the managed memory size can be set by {@link + * ExecutionOptions#SORT_PARTITION_MEMORY}. For {@link KeyedPartitionWindowedStream}, the + * managed memory size can be set by {@link ExecutionOptions#SORT_KEYED_PARTITION_MEMORY}. * * @param field The field 1-based index on which records is sorted. * @param order The order in which records is sorted. @@ -99,10 +98,9 @@ public interface PartitionWindowedStream<T> { * </ul> * * <p>This operator will use managed memory for the sort.For {@link - * NonKeyedPartitionWindowedStream}, the managed memory size can be set by - * "execution.sort.partition.memory" in {@link ExecutionOptions}. For {@link - * KeyedPartitionWindowedStream}, the managed memory size can be set by - * "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}. + * NonKeyedPartitionWindowedStream}, the managed memory size can be set by {@link + * ExecutionOptions#SORT_PARTITION_MEMORY}. For {@link KeyedPartitionWindowedStream}, the + * managed memory size can be set by {@link ExecutionOptions#SORT_KEYED_PARTITION_MEMORY}. * * @param field The field expression referring to the field on which records is sorted. * @param order The order in which records is sorted. @@ -114,10 +112,9 @@ public interface PartitionWindowedStream<T> { * Sorts the records according to a {@link KeySelector} in the specified order. * * <p>This operator will use managed memory for the sort.For {@link - * NonKeyedPartitionWindowedStream}, the managed memory size can be set by - * "execution.sort.partition.memory" in {@link ExecutionOptions}. For {@link - * KeyedPartitionWindowedStream}, the managed memory size can be set by - * "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}. + * NonKeyedPartitionWindowedStream}, the managed memory size can be set by {@link + * ExecutionOptions#SORT_PARTITION_MEMORY}. For {@link KeyedPartitionWindowedStream}, the + * managed memory size can be set by {@link ExecutionOptions#SORT_KEYED_PARTITION_MEMORY}. * * @param keySelector The key selector to extract key from the records for sorting. * @param order The order in which records is sorted.
