[hotfix][tests] Enable NetworkStackThroughputITCase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f633a80b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f633a80b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f633a80b Branch: refs/heads/master Commit: f633a80bb22011ca1e7a0e4fc7a754d79b213e00 Parents: 598cb66 Author: zentol <ches...@apache.org> Authored: Thu Apr 19 10:28:44 2018 +0200 Committer: zentol <ches...@apache.org> Committed: Tue Apr 24 13:30:07 2018 +0200 ---------------------------------------------------------------------- .../test/runtime/NetworkStackThroughputITCase.java | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f633a80b/flink-tests/src/test/java/org/apache/flink/test/runtime/NetworkStackThroughputITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/runtime/NetworkStackThroughputITCase.java b/flink-tests/src/test/java/org/apache/flink/test/runtime/NetworkStackThroughputITCase.java index 1b46f46..b5c233a 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/runtime/NetworkStackThroughputITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/runtime/NetworkStackThroughputITCase.java @@ -36,7 +36,7 @@ import org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup; import org.apache.flink.test.util.MiniClusterResource; import org.apache.flink.util.TestLogger; -import org.junit.Ignore; +import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -46,7 +46,6 @@ import java.util.concurrent.TimeUnit; /** * Manually test the throughput of the network stack. */ -@Ignore public class NetworkStackThroughputITCase extends TestLogger { private static final Logger LOG = LoggerFactory.getLogger(NetworkStackThroughputITCase.class); @@ -84,7 +83,7 @@ public class NetworkStackThroughputITCase extends TestLogger { // Determine the amount of data to send per subtask int dataVolumeGb = getTaskConfiguration().getInteger(NetworkStackThroughputITCase.DATA_VOLUME_GB_CONFIG_KEY, 1); - long dataMbPerSubtask = (dataVolumeGb * 1024) / getCurrentNumberOfSubtasks(); + long dataMbPerSubtask = (dataVolumeGb * 10) / getCurrentNumberOfSubtasks(); long numRecordsToEmit = (dataMbPerSubtask * 1024 * 1024) / SpeedTestRecord.RECORD_SIZE; LOG.info(String.format("%d/%d: Producing %d records (each record: %d bytes, total: %.2f GB)", @@ -209,6 +208,7 @@ public class NetworkStackThroughputITCase extends TestLogger { // ------------------------------------------------------------------------ + @Test public void testThroughput() throws Exception { Object[][] configParams = new Object[][]{ new Object[]{1, false, false, false, 4, 2}, @@ -335,13 +335,9 @@ public class NetworkStackThroughputITCase extends TestLogger { return jobGraph; } - private void runAllTests() throws Exception { - testThroughput(); + public static void main(String[] args) throws Exception { + new NetworkStackThroughputITCase().testThroughput(); System.out.println("Done."); } - - public static void main(String[] args) throws Exception { - new NetworkStackThroughputITCase().runAllTests(); - } }