[flink] 02/05: [hotfix][streaming][test] Allow AbstractStreamOperatorTestHarness to use managed memory for operator use case

[jark]

This is an automated email from the ASF dual-hosted git repository.

jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 88dc2fc61e466b8bdb73bc4b411444681b853e1d
Author: Jark Wu <j...@apache.org>
AuthorDate: Wed Jan 20 18:05:20 2021 +0800

    [hotfix][streaming][test] Allow AbstractStreamOperatorTestHarness to use 
managed memory for operator use case
---
 .../apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java
index 9dfb300..9d1a093 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java
@@ -255,6 +255,7 @@ public class AbstractStreamOperatorTestHarness<OUT> 
implements AutoCloseable {
         this.config.setStateBackendUsesManagedMemory(true);
         this.config.setManagedMemoryFractionOperatorOfUseCase(
                 ManagedMemoryUseCase.STATE_BACKEND, 1.0);
+        
this.config.setManagedMemoryFractionOperatorOfUseCase(ManagedMemoryUseCase.OPERATOR,
 1.0);
         this.executionConfig = env.getExecutionConfig();
         this.checkpointLock = new Object();