1. 修复ServerDriver类中Mapper的传出参数

This commit is contained in:
zhang.xin 2016-03-09 17:20:28 +08:00
parent 57f6aee7f3
commit 1b243501e2
1 changed files with 1 additions and 1 deletions

View File

@ -53,7 +53,7 @@ public class AnalysisServerDriver extends Configured implements Tool {
Scan scan = buildHBaseScan(args);
TableMapReduceUtil.initTableMapperJob(HBaseTableMetaData.TABLE_CALL_CHAIN.TABLE_NAME, scan, ChainBuildMapper.class,
Text.class, ChainInfo.class, job);
Text.class, Text.class, job);
job.setReducerClass(ChainBuildReducer.class);
job.setNumReduceTasks(Config.Reducer.REDUCER_NUMBER);