spring-data-mogodb执行mapreduce操作的时候转换异常(二)

由于依赖的时候1.0.1.RELEASE

spring-data-mongodb

org.springframework.data

1.0.1.RELEASE

在 源码中

org.springframework.data.mongodb.core.mapreduce.MapReduceResults

中新建对象的构造器，new的时候调用parseTime

public MapReduceResults(List mappedResults, DBObject rawResults) {

Assert.notNull(mappedResults);

Assert.notNull(rawResults);

this.mappedResults = mappedResults;

this.rawResults = rawResults;

parseTiming(rawResults);

parseCounts(rawResults);

if (rawResults.get("result") != null) {

this.outputCollection = (String) rawResults.get("result");

}

}

这个 在转换parseTime的时候数据

rawResults如下数据

{ "serverUsed" : "192.168.232.62:27017" , "results" : [//数据太多省略] , "timeMillis" : 39780 , "timing" : { "mapTime" : 28962 , "emitLoop" : 39780 , "reduceTime" : 2861 , "mode" : "mixed" , "total" : 39780} , "counts" : { "input" : 1922720 , "emit" : 1922720 , "reduce" : 19236 , "output" : 9} , "ok" : 1.0}

这行代码(Long) timing.get("mapTime")强转的时候就报错了。

if (timing != null) {

if (timing.get("mapTime") != null && timing.get("emitLoop") != null && timing.get("total") != null) {

mapReduceTiming = new MapReduceTiming((Long) timing.get("mapTime"), (Integer) timing.get("emitLoop"),

(Integer) timing.get("total"));

}

} else {

mapReduceTiming = new MapReduceTiming(-1, -1, -1);

}

个人修改成了1.0.3就在没有那个问题了。

spring-data-mongodb

org.springframework.data

1.0.3.RELEASE

运行成功。