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 2017/07/31 11:59:18 UTC
[11/12] flink git commit: [hotfix] [tests] fix
NetworkStackThroughputITCase not working anymore
[hotfix] [tests] fix NetworkStackThroughputITCase not working anymore
Invokable classes need to stay public in order to be successfully executed by
the TM.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3407a449
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3407a449
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3407a449
Branch: refs/heads/master
Commit: 3407a44922289dc4ddb3ff87687b8766affeaad9
Parents: 738dbbe
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Fri Jul 28 14:18:09 2017 +0200
Committer: zentol <ch...@apache.org>
Committed: Mon Jul 31 12:12:09 2017 +0200
----------------------------------------------------------------------
.../runtime/NetworkStackThroughputITCase.java | 31 +++++++++++++++++---
1 file changed, 27 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3407a449/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 ba3499f..92bf6d6 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
@@ -163,7 +163,14 @@ public class NetworkStackThroughputITCase extends TestLogger {
// ------------------------------------------------------------------------
- private static class SpeedTestProducer extends AbstractInvokable {
+ /**
+ * Invokable that produces records and allows slowdown via {@link #IS_SLOW_EVERY_NUM_RECORDS}
+ * and {@link #IS_SLOW_SENDER_CONFIG_KEY} and creates records of different data sizes via {@link
+ * #DATA_VOLUME_GB_CONFIG_KEY}.
+ *
+ * <p>NOTE: needs to be <tt>public</tt> so that a task can be run with this!
+ */
+ public static class SpeedTestProducer extends AbstractInvokable {
@Override
public void invoke() throws Exception {
@@ -198,7 +205,12 @@ public class NetworkStackThroughputITCase extends TestLogger {
}
}
- private static class SpeedTestForwarder extends AbstractInvokable {
+ /**
+ * Invokable that forwards incoming records.
+ *
+ * <p>NOTE: needs to be <tt>public</tt> so that a task can be run with this!
+ */
+ public static class SpeedTestForwarder extends AbstractInvokable {
@Override
public void invoke() throws Exception {
@@ -222,7 +234,13 @@ public class NetworkStackThroughputITCase extends TestLogger {
}
}
- private static class SpeedTestConsumer extends AbstractInvokable {
+ /**
+ * Invokable that consumes incoming records and allows slowdown via {@link
+ * #IS_SLOW_EVERY_NUM_RECORDS}.
+ *
+ * <p>NOTE: needs to be <tt>public</tt> so that a task can be run with this!
+ */
+ public static class SpeedTestConsumer extends AbstractInvokable {
@Override
public void invoke() throws Exception {
@@ -247,7 +265,12 @@ public class NetworkStackThroughputITCase extends TestLogger {
}
}
- private static class SpeedTestRecord implements IOReadableWritable {
+ /**
+ * Record type for the speed test.
+ *
+ * <p>NOTE: needs to be <tt>public</tt> to allow deserialization!
+ */
+ public static class SpeedTestRecord implements IOReadableWritable {
private static final int RECORD_SIZE = 128;