From 171e37e4518a6c0295e078f4499e4fa8d3a2724a Mon Sep 17 00:00:00 2001 From: Greg Hogan Date: Mon, 22 Feb 2016 11:21:40 -0500 Subject: [PATCH] [FLINK-3467] Remove superfluous objects from DataSourceTask.invoke --- .../flink/runtime/operators/DataSourceTask.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java index 93a4f9c03b1f4d..9571479bed6693 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java @@ -152,26 +152,19 @@ public void invoke() throws Exception { final Collector output = this.output; if (objectReuseEnabled) { - OT reuse1 = serializer.createInstance(); - OT reuse2 = serializer.createInstance(); - OT reuse3 = serializer.createInstance(); + OT reuse = serializer.createInstance(); // as long as there is data to read while (!this.taskCanceled && !format.reachedEnd()) { OT returned; - if ((returned = format.nextRecord(reuse1)) != null) { + if ((returned = format.nextRecord(reuse)) != null) { output.collect(returned); - - reuse1 = reuse2; - reuse2 = reuse3; - reuse3 = returned; } } } else { // as long as there is data to read while (!this.taskCanceled && !format.reachedEnd()) { - OT returned; if ((returned = format.nextRecord(serializer.createInstance())) != null) { output.collect(returned);