You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/25 07:32:18 UTC
[04/10] flink git commit: [hotfix][tests] Enable
NetworkStackThroughputITCase
[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 <ch...@apache.org>
Authored: Thu Apr 19 10:28:44 2018 +0200
Committer: zentol <ch...@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();
- }
}