usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject [1/2] incubator-usergrid git commit: Fixes exception throwing removal
Date Mon, 06 Apr 2015 17:40:15 GMT
Repository: incubator-usergrid
Updated Branches:
  refs/heads/USERGRID-536 ba41bd27c -> 5a40ff553


Fixes exception throwing removal


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/543e13bf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/543e13bf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/543e13bf

Branch: refs/heads/USERGRID-536
Commit: 543e13bf106864e29c7b21c37caabefba33790d3
Parents: ba41bd2
Author: Todd Nine <tnine@apigee.com>
Authored: Mon Apr 6 09:04:19 2015 -0600
Committer: Todd Nine <tnine@apigee.com>
Committed: Mon Apr 6 09:08:44 2015 -0600

----------------------------------------------------------------------
 .../persistence/index/impl/EsIndexBufferConsumerImpl.java       | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/543e13bf/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
index 558f796..0648e9b 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
@@ -270,7 +270,7 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer
{
      * @param bulkRequest
      */
     private void sendRequest(BulkRequestBuilder bulkRequest) {
-        //nothing to do, we haven't added anthing to the index
+        //nothing to do, we haven't added anything to the index
         if (bulkRequest.numberOfActions() == 0) {
             return;
         }
@@ -305,8 +305,7 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer
{
         }
 
         if ( error ) {
-            // TODO: throw error once onErrorResumeNext() implemented in startWorker()
-            //throw new RuntimeException("Error during processing of bulk index operations")
+            throw new RuntimeException("Error during processing of bulk index operations
one of the responses failed.  Check previous log entries");
         }
     }
 }


Mime
View raw message