flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject incubator-flink git commit: [Flink-1262] inconsistency between CsvReader.java and TupleGenerator.java
Date Thu, 20 Nov 2014 17:37:00 GMT
Repository: incubator-flink
Updated Branches:
  refs/heads/master 4a74f3281 -> b3e5ed0ba


[Flink-1262] inconsistency between CsvReader.java and TupleGenerator.java

This closes #222


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/b3e5ed0b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/b3e5ed0b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/b3e5ed0b

Branch: refs/heads/master
Commit: b3e5ed0ba745d9b628cb0a89101b62146503ea8a
Parents: 4a74f32
Author: dukechain <chenxuecnu@gmail.com>
Authored: Thu Nov 20 14:39:42 2014 +0100
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Thu Nov 20 18:36:06 2014 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/flink/api/java/tuple/TupleGenerator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b3e5ed0b/flink-java/src/main/java/org/apache/flink/api/java/tuple/TupleGenerator.java
----------------------------------------------------------------------
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 de620f9..fab1f75 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<Tuple" + numFields + "<");
 			appendTupleTypeGenerics(sb, numFields);
-			sb.append(">>(executionContext, inputFormat, types, DataSet.getCallLocationName());\n");
+			sb.append(">>(executionContext, inputFormat, types, Utils.getCallLocationName());\n");
 
 			// end of method
 			sb.append("\t}\n");


Mime
View raw message