我正在使用ApacheStorm，我想在mongodb数据库上编写代码，但有时它会抛出

Caused by: com.mongodb.MongoException$DuplicateKey: { "serverUsed" : "127.0.0.1:27017" , "ok" : 1 , "n" : 0 , "updatedExisting" : false , "err" : "E11000 duplicate key error collection: TesiMarco.UserPostNew_Hampshire index: _id_ dup key: { : \"mainelyinspired\" }" , "code" : 11000}

使用并行选项时。特别是我的螺栓在执行：

public void execute(Tuple input, BasicOutputCollector collector) {
    String user=input.getString(0);
    DBObject query=new BasicDBObject("_id",user);
    DBObject toUpdate=new BasicDBObject("$inc",new BasicDBObject("numeroPost",1));
    collection.update(query,toUpdate,true,false);
}

但它在键上发现了重复的错误。如何执行这部分多线程？