This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 37e0fb44162b4c777ae47173d61babd3fb4ae7fe Author: Piotr Nowojski <[email protected]> AuthorDate: Wed Oct 28 18:20:45 2020 +0100 [hotfix][test] Fix StreamConfig propagation to StreamTask in StreamTaskMailboxTestHarnessBuilder --- .../streaming/runtime/tasks/StreamTaskMailboxTestHarnessBuilder.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHarnessBuilder.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHarnessBuilder.java index dc69ed4..25bec13 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHarnessBuilder.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHarnessBuilder.java @@ -74,8 +74,7 @@ public class StreamTaskMailboxTestHarnessBuilder<OUT> { protected long memorySize = 1024 * 1024; protected int bufferSize = 1024; protected Configuration jobConfig = new Configuration(); - protected Configuration taskConfig = new Configuration(); - protected StreamConfig streamConfig = new StreamConfig(taskConfig); + protected StreamConfig streamConfig = new StreamConfig(new Configuration()); protected LocalRecoveryConfig localRecoveryConfig = TestLocalRecoveryConfig.disabled(); @Nullable protected StreamTestSingleInputGate[] inputGates; @@ -138,7 +137,7 @@ public class StreamTaskMailboxTestHarnessBuilder<OUT> { StreamMockEnvironment streamMockEnvironment = new StreamMockEnvironment( jobConfig, - taskConfig, + streamConfig.getConfiguration(), executionConfig, memorySize, new MockInputSplitProvider(),
