This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4d1c9927f77b11f6990e447856fac6627a46bdcf Author: Aljoscha Krettek <[email protected]> AuthorDate: Thu Dec 17 10:36:34 2020 +0100 [FLINK-20646] Update memory requirements for ReduceTransformation This closes #14413. --- .../flink/streaming/api/transformations/ReduceTransformation.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/ReduceTransformation.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/ReduceTransformation.java index 8dee1637..f5b5406 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/ReduceTransformation.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/ReduceTransformation.java @@ -56,6 +56,8 @@ public final class ReduceTransformation<IN, K> extends PhysicalTransformation<IN this.reducer = reducer; this.keySelector = keySelector; this.keyTypeInfo = keyTypeInfo; + + updateManagedMemoryStateBackendUseCase(true); } @Override
