Skip to content

Commit 7435124

Browse files
committed
[hotfix] Correct the option key for sortPartition
1 parent 0272c00 commit 7435124

File tree

1 file changed

+9
-12
lines changed

1 file changed

+9
-12
lines changed

flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/PartitionWindowedStream.java

Lines changed: 9 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -72,10 +72,9 @@ <ACC, R> SingleOutputStreamOperator<R> aggregate(
7272
* records must be {@link Tuple}.
7373
*
7474
* <p>This operator will use managed memory for the sort.For {@link
75-
* NonKeyedPartitionWindowedStream}, the managed memory size can be set by
76-
* "execution.sort.partition.memory" in {@link ExecutionOptions}. For {@link
77-
* KeyedPartitionWindowedStream}, the managed memory size can be set by
78-
* "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}.
75+
* NonKeyedPartitionWindowedStream}, the managed memory size can be set by {@link
76+
* ExecutionOptions#SORT_PARTITION_MEMORY}. For {@link KeyedPartitionWindowedStream}, the
77+
* managed memory size can be set by {@link ExecutionOptions#SORT_KEYED_PARTITION_MEMORY}.
7978
*
8079
* @param field The field 1-based index on which records is sorted.
8180
* @param order The order in which records is sorted.
@@ -99,10 +98,9 @@ <ACC, R> SingleOutputStreamOperator<R> aggregate(
9998
* </ul>
10099
*
101100
* <p>This operator will use managed memory for the sort.For {@link
102-
* NonKeyedPartitionWindowedStream}, the managed memory size can be set by
103-
* "execution.sort.partition.memory" in {@link ExecutionOptions}. For {@link
104-
* KeyedPartitionWindowedStream}, the managed memory size can be set by
105-
* "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}.
101+
* NonKeyedPartitionWindowedStream}, the managed memory size can be set by {@link
102+
* ExecutionOptions#SORT_PARTITION_MEMORY}. For {@link KeyedPartitionWindowedStream}, the
103+
* managed memory size can be set by {@link ExecutionOptions#SORT_KEYED_PARTITION_MEMORY}.
106104
*
107105
* @param field The field expression referring to the field on which records is sorted.
108106
* @param order The order in which records is sorted.
@@ -114,10 +112,9 @@ <ACC, R> SingleOutputStreamOperator<R> aggregate(
114112
* Sorts the records according to a {@link KeySelector} in the specified order.
115113
*
116114
* <p>This operator will use managed memory for the sort.For {@link
117-
* NonKeyedPartitionWindowedStream}, the managed memory size can be set by
118-
* "execution.sort.partition.memory" in {@link ExecutionOptions}. For {@link
119-
* KeyedPartitionWindowedStream}, the managed memory size can be set by
120-
* "execution.sort.keyed.partition.memory" in {@link ExecutionOptions}.
115+
* NonKeyedPartitionWindowedStream}, the managed memory size can be set by {@link
116+
* ExecutionOptions#SORT_PARTITION_MEMORY}. For {@link KeyedPartitionWindowedStream}, the
117+
* managed memory size can be set by {@link ExecutionOptions#SORT_KEYED_PARTITION_MEMORY}.
121118
*
122119
* @param keySelector The key selector to extract key from the records for sorting.
123120
* @param order The order in which records is sorted.

0 commit comments

Comments
 (0)