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);