[hotfix] Correct the option key for sortPartition

green241 · Apr 8, 2024 · 32ab253 · 32ab253
1 parent 2bfb7c0
commit 32ab253
Showing 1 changed file with 9 additions and 12 deletions.
diff --git a/...java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java b/...java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java
@@ -72,10 +72,9 @@ <ACC, R> SingleOutputStreamOperator<R> aggregate(
      * 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 @@ <ACC, R> SingleOutputStreamOperator<R> aggregate(
      * </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 @@ <ACC, R> SingleOutputStreamOperator<R> aggregate(
      * 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.