flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [11/23] git commit: [FLINK-1110] Fix HadoopInputFormat to work without prior serialization.
Date Fri, 03 Oct 2014 16:25:07 GMT
[FLINK-1110] Fix HadoopInputFormat to work without prior serialization.


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

Branch: refs/heads/master
Commit: ff5ddd50f31ca5cc8556ba012bf4aeb9b501baf4
Parents: 15f2544
Author: Stephan Ewen <sewen@apache.org>
Authored: Thu Oct 2 01:54:26 2014 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Fri Oct 3 16:22:34 2014 +0200

----------------------------------------------------------------------
 .../apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java  | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/ff5ddd50/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
index eca661e..296304a 100644
--- a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
+++ b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
@@ -78,6 +78,7 @@ public class HadoopInputFormat<K extends Writable, V extends Writable>
implement
 		this.valueClass = value;
 		HadoopUtils.mergeHadoopConf(job);
 		this.jobConf = job;
+		ReflectionUtils.setConf(mapredInputFormat, jobConf);
 	}
 	
 	public void setJobConf(JobConf job) {


Mime
View raw message