flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [11/12] flink git commit: [hotfix] [tests] fix NetworkStackThroughputITCase not working anymore
Date Mon, 31 Jul 2017 11:59:18 GMT
[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 <nico@data-artisans.com>
Authored: Fri Jul 28 14:18:09 2017 +0200
Committer: zentol <chesnay@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;
 


Mime
View raw message