You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by gr...@apache.org on 2015/08/12 23:21:59 UTC
[1/3] incubator-usergrid git commit: Fixes subscription death on error
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o-dev e3a4a9571 -> d7310c503
Fixes subscription death on error
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/3f821f58
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/3f821f58
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/3f821f58
Branch: refs/heads/two-dot-o-dev
Commit: 3f821f5803c467b45148c51ba192fd957146dc1e
Parents: e3a4a95
Author: Todd Nine <tn...@apigee.com>
Authored: Wed Aug 12 14:59:46 2015 -0600
Committer: Todd Nine <tn...@apigee.com>
Committed: Wed Aug 12 14:59:46 2015 -0600
----------------------------------------------------------------------
.../index/impl/EsIndexBufferConsumerImpl.java | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/3f821f58/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 457a900..ed70c62 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
@@ -177,7 +177,7 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
batchOperation.doOperation( client, bulkRequestBuilder );
} ) )
//write them
- .doOnNext( bulkRequestBuilder -> sendRequest( bulkRequestBuilder ) ).doOnError( t -> log.error( "Unable to process batches", t ) );
+ .doOnNext( bulkRequestBuilder -> sendRequest( bulkRequestBuilder ) );
//now that we've processed them all, ack the futures after our last batch comes through
@@ -194,9 +194,8 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
//mark this as done
return processedIndexOperations.doOnNext( processedIndexOp -> {
processedIndexOp.done();
- roundtripTimer.update(System.currentTimeMillis() - processedIndexOp.getCreationTime());
- }
- ).doOnError(t -> log.error("Unable to ack futures", t));
+ roundtripTimer.update( System.currentTimeMillis() - processedIndexOp.getCreationTime() );
+ } );
}
@@ -270,7 +269,11 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
* Send the data through the buffer
*/
public void send( final IndexOperationMessage indexOp ) {
- subscriber.onNext( indexOp );
+ try {
+ subscriber.onNext( indexOp );
+ }catch(Exception e){
+ log.error( "Unable to process message for indexOp {}, error follows.", indexOp, e );
+ }
}
[2/3] incubator-usergrid git commit: Fixes max size bug in mapping on
unanalyzed string.
Posted by gr...@apache.org.
Fixes max size bug in mapping on unanalyzed string.
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/9b829ef4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/9b829ef4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/9b829ef4
Branch: refs/heads/two-dot-o-dev
Commit: 9b829ef4a8ec988a32c78c31030b1705eb002f1c
Parents: 3f821f5
Author: Todd Nine <tn...@apigee.com>
Authored: Wed Aug 12 15:05:04 2015 -0600
Committer: Todd Nine <tn...@apigee.com>
Committed: Wed Aug 12 15:05:04 2015 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/persistence/index/usergrid-mappings.json | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/9b829ef4/stack/corepersistence/queryindex/src/main/resources/org/apache/usergrid/persistence/index/usergrid-mappings.json
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/resources/org/apache/usergrid/persistence/index/usergrid-mappings.json b/stack/corepersistence/queryindex/src/main/resources/org/apache/usergrid/persistence/index/usergrid-mappings.json
index adfb20d..da8e5d2 100644
--- a/stack/corepersistence/queryindex/src/main/resources/org/apache/usergrid/persistence/index/usergrid-mappings.json
+++ b/stack/corepersistence/queryindex/src/main/resources/org/apache/usergrid/persistence/index/usergrid-mappings.json
@@ -81,7 +81,8 @@
"exact": {
"type": "string",
"index": "not_analyzed",
- "doc_values": true
+ "doc_values": true,
+ "ignore_above": 10922
}
}
},
[3/3] incubator-usergrid git commit: Fixes-rethrow
Posted by gr...@apache.org.
Fixes-rethrow
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/d7310c50
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/d7310c50
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/d7310c50
Branch: refs/heads/two-dot-o-dev
Commit: d7310c5037af3824c38fda03b78e7146b6e9f057
Parents: 9b829ef
Author: Todd Nine <tn...@apigee.com>
Authored: Wed Aug 12 15:18:03 2015 -0600
Committer: Todd Nine <tn...@apigee.com>
Committed: Wed Aug 12 15:18:03 2015 -0600
----------------------------------------------------------------------
.../usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d7310c50/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 ed70c62..2c7122b 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
@@ -272,7 +272,9 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
try {
subscriber.onNext( indexOp );
}catch(Exception e){
+ //re-throws so the caller can determine failover
log.error( "Unable to process message for indexOp {}, error follows.", indexOp, e );
+ throw e;
}
}