Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-9744 Set io.serializations correctly in HFileOutputFormat.configureIncrementalLoad 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1531188 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2013-10-11 03:59:43 +00:00
parent 8c47f89932
commit 71e8021b65
2 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat.java
View File

@ -335,6 +335,7 @@ public class HFileOutputFormat extends FileOutputFormat<ImmutableBytesWritable,
} }
conf.setStrings("io.serializations", conf.get("io.serializations"), conf.setStrings("io.serializations", conf.get("io.serializations"),
MutationSerialization.class.getName(), ResultSerialization.class.getName(),
KeyValueSerialization.class.getName()); KeyValueSerialization.class.getName());
// Use table's region boundaries for TOP split points. // Use table's region boundaries for TOP split points.

3
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/ImportTsv.java
View File

@ -303,9 +303,6 @@ public class ImportTsv extends Configured implements Tool {
Class mapperClass = mapperClassName != null ? Class mapperClass = mapperClassName != null ?
Class.forName(mapperClassName) : DEFAULT_MAPPER; Class.forName(mapperClassName) : DEFAULT_MAPPER;
conf.setStrings("io.serializations", conf.get("io.serializations"),
MutationSerialization.class.getName(), ResultSerialization.class.getName());
String tableName = args[0]; String tableName = args[0];
Path inputDir = new Path(args[1]); Path inputDir = new Path(args[1]);
String jobName = conf.get(JOB_NAME_CONF_KEY,NAME + "_" + tableName); String jobName = conf.get(JOB_NAME_CONF_KEY,NAME + "_" + tableName);