This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.8 by this push:
new e620844 [FLINK-12012] [tests] BroadcastStateITCase properly inherity
from AbstractTestBase
e620844 is described below
commit e620844ceed020e3d976aa4dc976b1ff8bf3fc80
Author: Stephan Ewen <[email protected]>
AuthorDate: Mon Mar 25 19:22:11 2019 +0100
[FLINK-12012] [tests] BroadcastStateITCase properly inherity from
AbstractTestBase
The test previously used the default local environment (and thus embedded
mini cluster),
where the parallelism depends on the number of CPU cores.
That makes the network buffer consumption non-deterministic.
The test now extends AbstractTestBase which uses a test environment with
well-defined parallelism and memory footprint.
---
.../org/apache/flink/test/streaming/runtime/BroadcastStateITCase.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BroadcastStateITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BroadcastStateITCase.java
index 9400614..da802fd 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BroadcastStateITCase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BroadcastStateITCase.java
@@ -31,6 +31,7 @@ import
org.apache.flink.streaming.api.functions.co.BroadcastProcessFunction;
import
org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
import org.apache.flink.streaming.api.watermark.Watermark;
+import org.apache.flink.test.util.AbstractTestBase;
import org.apache.flink.util.Collector;
import org.junit.Test;
@@ -45,7 +46,7 @@ import static org.junit.Assert.assertEquals;
/**
* ITCase for the {@link org.apache.flink.api.common.state.BroadcastState}.
*/
-public class BroadcastStateITCase {
+public class BroadcastStateITCase extends AbstractTestBase {
@Test
public void testKeyedWithBroadcastTranslation() throws Exception {
