Revision 45900
Added by Claudio Atzori about 7 years ago
| modules/cnr-mongo-mdstore/trunk/src/main/java/eu/dnetlib/data/mdstore/modular/mongodb/MDStoreTransactionManagerImpl.java | ||
|---|---|---|
| 659 | 659 |
private void updateIncremental(final String transactionId, final String currentId) {
|
| 660 | 660 |
final MongoCollection<DBObject> transaction = db.getCollection(transactionId, DBObject.class); |
| 661 | 661 |
final MongoCollection<DBObject> mdstore = db.getCollection(currentId, DBObject.class); |
| 662 |
final FindIterable<DBObject> it = transaction.find(); |
|
| 663 |
for (DBObject currentObj : it){
|
|
| 662 |
final FindIterable<DBObject> it = transaction.find().noCursorTimeout(true);
|
|
| 663 |
for (DBObject currentObj : it) {
|
|
| 664 | 664 |
|
| 665 | 665 |
BasicDBObject newObj = new BasicDBObject(); |
| 666 | 666 |
|
Also available in: Unified diff
avoid mongodb cursor to timeout upon long commits #2616