From 17493d3169f1626bb35d0710f757cb07f85555d8 Mon Sep 17 00:00:00 2001
From: Alessandro Pieve <alessandro.pieve@isti.cnr.it>
Date: Tue, 21 Feb 2017 14:02:24 +0000
Subject: [PATCH] git-svn-id:
 https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-analytics-persistence-couchbase@144017
 82a268e6-3cf1-43bd-a215-b396298e98cf

---
 .../couchbase/AccountingPersistenceQueryCouchBase.java      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java b/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
index a719060..6d5336c 100644
--- a/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
+++ b/src/main/java/org/gcube/accounting/analytics/persistence/couchbase/AccountingPersistenceQueryCouchBase.java
@@ -65,6 +65,7 @@ import com.couchbase.client.java.query.dsl.Expression;
 import com.couchbase.client.java.query.dsl.Sort;
 import com.couchbase.client.java.query.dsl.path.GroupByPath;
 import com.couchbase.client.java.query.dsl.path.OffsetPath;
+import com.couchbase.client.java.view.OnError;
 import com.couchbase.client.java.view.ViewQuery;
 import com.couchbase.client.java.view.ViewResult;
 import com.couchbase.client.java.view.ViewRow;
@@ -1590,6 +1591,7 @@ AccountingPersistenceBackendQuery {
 				query.endKey(startKeyTmp);
 				query.descending(true);
 				query.limit(1);
+				query.onError(OnError.STOP);
 
 			}
 			else{
@@ -1598,6 +1600,7 @@ AccountingPersistenceBackendQuery {
 				query.startKey(startKeyTmp);
 				query.endKey(endKeyTmp);
 				query.descending(false);
+				query.onError(OnError.STOP);
 			}
 
 			logger.trace("query row:{}",query.toString());
@@ -1608,7 +1611,8 @@ AccountingPersistenceBackendQuery {
 				logger.error(e.getLocalizedMessage());
 				throw e;
 			}
-
+			
+			logger.trace("viewResult row:{}",viewResult.toString());
 			Map<String, Float> map = new HashMap<String, Float>();
 
 			for (ViewRow row : viewResult) {