This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new d4a0ecc [FLINK-12012] [tests] BroadcastStateITCase properly inherits
from AbstractTestBase
d4a0ecc is described below
commit d4a0ecce47ee2b2fdd579634ea23855c23164087
Author: Stephan Ewen <[email protected]>
AuthorDate: Mon Mar 25 19:22:11 2019 +0100
[FLINK-12012] [tests] BroadcastStateITCase properly inherits 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 {
