From 7614ca8f86fcac293dadcf99c74e6736d1a002a3 Mon Sep 17 00:00:00 2001 From: wusheng Date: Fri, 22 Jan 2016 21:39:19 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9reduce=E7=9A=84=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/cloud/skywalking/analysis/AnalysisServerDriver.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 97552912b..73d74476b 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 @@ -45,8 +45,8 @@ public class AnalysisServerDriver extends Configured implements Tool { TableMapReduceUtil.initTableMapperJob(Config.HBase.CALL_CHAIN_TABLE_NAME, scan, Categorize2ChainMapper.class, String.class, ChainInfo.class, job); - - TableMapReduceUtil.initTableReducerJob(Config.HBase.CALL_CHAIN_TABLE_NAME, Categorize2ChainReduce.class, job); + + job.setReducerClass(Categorize2ChainReduce.class); return job.waitForCompletion(true) ? 0 : 1; }