diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/StreamRecordTest.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/StreamRecordTest.java index 28926424ae051b3ecc192c43f568c1673ff7a314..00d8353e3b62ed46b4d0ed37a5c046692d5ebe6a 100644 --- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/StreamRecordTest.java +++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/StreamRecordTest.java @@ -249,7 +249,7 @@ public class StreamRecordTest { t2 = System.nanoTime() - t; System.out.println("getFieldFast:\t" + t2 + " ns"); - StreamRecord record25 = new StreamRecord( + StreamRecord record20 = new StreamRecord( new Tuple20( 0, 42L, "Stratosphere", "Streaming", "Stratosphere", "Stratosphere", "Streaming", "Stratosphere", @@ -260,7 +260,7 @@ public class StreamRecordTest { t = System.nanoTime(); for (int i = 0; i < ITERATION; i++) { - record25.getField(0, i % 20); + record20.getField(0, i % 20); } t2 = System.nanoTime() - t; System.out.println("Tuple20"); @@ -268,7 +268,7 @@ public class StreamRecordTest { t = System.nanoTime(); for (int i = 0; i < ITERATION; i++) { - record25.getFieldFast(0, i % 20); + record20.getFieldFast(0, i % 20); } t2 = System.nanoTime() - t; System.out.println("getFieldFast:\t" + t2 + " ns");