From b3e5ed0ba745d9b628cb0a89101b62146503ea8a Mon Sep 17 00:00:00 2001 From: dukechain Date: Thu, 20 Nov 2014 14:39:42 +0100 Subject: [PATCH] [Flink-1262] inconsistency between CsvReader.java and TupleGenerator.java This closes #222 --- .../java/org/apache/flink/api/java/tuple/TupleGenerator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java b/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java index de620f98e30..fab1f75844c 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java @@ -484,7 +484,7 @@ class TupleGenerator { // return sb.append("\t\treturn new DataSource>(executionContext, inputFormat, types, DataSet.getCallLocationName());\n"); + sb.append(">>(executionContext, inputFormat, types, Utils.getCallLocationName());\n"); // end of method sb.append("\t}\n"); -- GitLab