You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2014/11/20 18:37:00 UTC
incubator-flink git commit: [Flink-1262] inconsistency between
CsvReader.java and TupleGenerator.java
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 <ch...@gmail.com>
Authored: Thu Nov 20 14:39:42 2014 +0100
Committer: Robert Metzger <rm...@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");