You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gora.apache.org by dr...@apache.org on 2015/08/03 18:46:45 UTC
gora git commit: GORA-426 MongoDB cursor timeout on long running
parse job (Alexander Yastrebov via drazzib)
Repository: gora
Updated Branches:
refs/heads/master bb09d8916 -> b0c9e89f8
GORA-426 MongoDB cursor timeout on long running parse job (Alexander Yastrebov via drazzib)
closes apache/gora#27
Project: http://git-wip-us.apache.org/repos/asf/gora/repo
Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/b0c9e89f
Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/b0c9e89f
Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/b0c9e89f
Branch: refs/heads/master
Commit: b0c9e89f84b2e2310bb19f3ad13d91873ed6738f
Parents: bb09d89
Author: Damien Raude-Morvan <dr...@drazzib.com>
Authored: Mon Aug 3 18:45:01 2015 +0200
Committer: Damien Raude-Morvan <dr...@drazzib.com>
Committed: Mon Aug 3 18:45:46 2015 +0200
----------------------------------------------------------------------
CHANGES.txt | 2 ++
.../src/main/java/org/apache/gora/mongodb/store/MongoStore.java | 1 +
2 files changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/gora/blob/b0c9e89f/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 1ac61d5..ba06b7b 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -5,6 +5,8 @@
Apache Gora 0.6.1 Release - 02/03/2015 (dd/mm/yyyy)
Release Report - http://s.apache.org/l69
+* GORA-426 MongoDB cursor timeout on long running parse job (Alexander Yastrebov via drazzib)
+
* GORA-424 Cache cursor size to improve performance (Alexander Yastrebov via drazzib)
* GORA-423 BSONDecorator returns empty string for null field value (Alexander Yastrebov via drazzib)
http://git-wip-us.apache.org/repos/asf/gora/blob/b0c9e89f/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
----------------------------------------------------------------------
diff --git a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java b/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
index 2eea3b8..e1abe0f 100644
--- a/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
+++ b/gora-mongodb/src/main/java/org/apache/gora/mongodb/store/MongoStore.java
@@ -469,6 +469,7 @@ public class MongoStore<K, T extends PersistentBase> extends
if (query.getLimit() > 0)
cursor = cursor.limit((int) query.getLimit());
cursor.batchSize(100);
+ cursor.addOption(Bytes.QUERYOPTION_NOTIMEOUT);
// Build the result
MongoDBResult<K, T> mongoResult = new MongoDBResult<K, T>(this, query);