From 1b243501e2a86130beda63266f335b505dd3f81e Mon Sep 17 00:00:00 2001 From: "zhang.xin" Date: Wed, 9 Mar 2016 17:20:28 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E4=BF=AE=E5=A4=8DServerDriver=E7=B1=BB?= =?UTF-8?q?=E4=B8=ADMapper=E7=9A=84=E4=BC=A0=E5=87=BA=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java index cbbb3b580..ef3d57aaa 100644 --- a/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java +++ b/skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java @@ -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);