Repository: flink Updated Branches: refs/heads/master 7206b0ed2 -> 7ee0425a3
[hotfix] Fix NPE in NetworkStackThroughputITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ee0425a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ee0425a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7ee0425a Branch: refs/heads/master Commit: 7ee0425a3467f9cf8d1dc967c99b5bb6c29c1745 Parents: 7206b0e Author: Robert Metzger <rmetz...@apache.org> Authored: Mon Jul 4 12:32:10 2016 +0200 Committer: Robert Metzger <rmetz...@apache.org> Committed: Mon Jul 4 12:32:10 2016 +0200 ---------------------------------------------------------------------- .../apache/flink/test/runtime/NetworkStackThroughputITCase.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7ee0425a/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 5506f55..3d0e5ab 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 @@ -287,9 +287,12 @@ public class NetworkStackThroughputITCase { config.setInteger(NUM_SLOTS_PER_TM_CONFIG_KEY, (Integer) p[5]); TestBaseWrapper test = new TestBaseWrapper(config); + test.startCluster(); System.out.println(Arrays.toString(p)); test.testProgram(); + + test.stopCluster(); } }
