Created
May 18, 2011 18:36
-
-
Save sebaes/979208 to your computer and use it in GitHub Desktop.
Loop causing the exception
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
{ | |
"p" : { | |
"_all" : {"enabled" : "false"}, | |
"_source" : { | |
"enabled" : true, | |
"compress" : true | |
}, | |
"_type" : { | |
"index" : "no", | |
"store" : "no" | |
}, | |
"dynamic" : "strict", | |
"properties" : { | |
"_analyzer" : { | |
"type" : "string", | |
"store" : "no", | |
"index" : "no" | |
}, | |
"titulo" : { | |
"type" : "string", | |
"store" : "no", | |
"index" : "analyzed", | |
"term_vector" : "with_positions_offsets" | |
}, | |
"random" : { | |
"type" : "float", | |
"store" : "no" | |
} | |
} | |
} | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Exception in thread "Main Thread" java.util.concurrent.ExecutionException: org.elasticsearch.action.search.SearchPhaseExecutionException: Failed to execute phase [query_fetch], total failure; shardFailures {[RqBL-1pETpuksJqhNLai4A][index1][1]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][1]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][2]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][2]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][4]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][4]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][3]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][3]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][0]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][0]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: } | |
at org.elasticsearch.common.util.concurrent.AbstractFuture$Sync.complete(AbstractFuture.java:320) | |
at org.elasticsearch.common.util.concurrent.AbstractFuture$Sync.setException(AbstractFuture.java:297) | |
at org.elasticsearch.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:129) | |
at org.elasticsearch.action.support.AdapterActionFuture.onFailure(AdapterActionFuture.java:87) | |
at org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction.onFirstPhaseResult(TransportSearchTypeAction.java:248) | |
at org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction.access$400(TransportSearchTypeAction.java:75) | |
at org.elasticsearch.action.search.type.TransportSearchTypeAction$BaseAsyncAction$3.onFailure(TransportSearchTypeAction.java:198) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$5.handleException(SearchServiceTransportAction.java:241) | |
at org.elasticsearch.transport.netty.MessageChannelHandler.handleException(MessageChannelHandler.java:156) | |
at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java:147) | |
at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java:99) | |
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80) | |
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:545) | |
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:754) | |
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:302) | |
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:317) | |
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.java:299) | |
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDecoder.java:214) | |
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80) | |
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:545) | |
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:540) | |
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:274) | |
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:261) | |
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:349) | |
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:280) | |
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200) | |
at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108) | |
at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907) | |
at java.lang.Thread.run(Thread.java:619) | |
Caused by: org.elasticsearch.action.search.SearchPhaseExecutionException: Failed to execute phase [query_fetch], total failure; shardFailures {[RqBL-1pETpuksJqhNLai4A][index1][1]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][1]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][2]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][2]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][4]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][4]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][3]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][3]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: }{[RqBL-1pETpuksJqhNLai4A][index1][0]: RemoteTransportException[[Utgard-Loki][inet[/10.0.0.1:9300]][search/phase/query+fetch]]; nested: QueryPhaseExecutionException[[index1][0]: query[filtered(random:[0.0 TO 1.0])->FilterCacheFilterWrapper(titulo:whatever)],from[0],size[100]: Query Failed [Failed to execute main query]]; nested: } | |
... 27 more |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[2011-05-21 17:26:36,756][INFO ][monitor.jvm ] [Kro] [gc][Garbage collection optimized for throughput Young Collector][9] took [2.4h]/[143ms], reclaimed [225.3mb], leaving [86.7mb] used, max [1.9gb] | |
Patched version just for sebastian, look below for the stack trace, thanks! | |
java.lang.NullPointerException | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.next(NumericRangeQuery.java:532) | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.<init>(NumericRangeQuery.java:476) | |
at org.apache.lucene.search.NumericRangeQuery.getEnum(NumericRangeQuery.java:303) | |
at org.apache.lucene.search.TermCollectingRewrite.collectTerms(TermCollectingRewrite.java:34) | |
at org.apache.lucene.search.ConstantScoreAutoRewrite.rewrite(ConstantScoreAutoRewrite.java:87) | |
at org.apache.lucene.search.MultiTermQuery$ConstantScoreAutoRewrite.rewrite(MultiTermQuery.java:215) | |
at org.apache.lucene.search.MultiTermQuery.rewrite(MultiTermQuery.java:291) | |
at org.apache.lucene.search.FilteredQuery.rewrite(FilteredQuery.java:173) | |
at org.apache.lucene.search.IndexSearcher.rewrite(IndexSearcher.java:582) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.rewrite(ContextIndexSearcher.java:116) | |
at org.apache.lucene.search.Query.weight(Query.java:100) | |
at org.apache.lucene.search.IndexSearcher.createWeight(IndexSearcher.java:652) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.createWeight(ContextIndexSearcher.java:126) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:291) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:279) | |
at org.elasticsearch.search.query.QueryPhase.execute(QueryPhase.java:211) | |
at org.elasticsearch.search.SearchService.executeFetchPhase(SearchService.java:280) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:501) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:492) | |
at org.elasticsearch.transport.netty.MessageChannelHandler$RequestHandler.run(MessageChannelHandler.java:236) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907) | |
at java.lang.Thread.run(Thread.java:619) | |
Patched version just for sebastian, look below for the stack trace, thanks! | |
Patched version just for sebastian, look below for the stack trace, thanks! | |
java.lang.NullPointerException | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.next(NumericRangeQuery.java:532) | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.<init>(NumericRangeQuery.java:476) | |
at org.apache.lucene.search.NumericRangeQuery.getEnum(NumericRangeQuery.java:303) | |
at org.apache.lucene.search.TermCollectingRewrite.collectTerms(TermCollectingRewrite.java:34) | |
at org.apache.lucene.search.ConstantScoreAutoRewrite.rewrite(ConstantScoreAutoRewrite.java:87) | |
at org.apache.lucene.search.MultiTermQuery$ConstantScoreAutoRewrite.rewrite(MultiTermQuery.java:215) | |
at org.apache.lucene.search.MultiTermQuery.rewrite(MultiTermQuery.java:291) | |
at org.apache.lucene.search.FilteredQuery.rewrite(FilteredQuery.java:173) | |
at org.apache.lucene.search.IndexSearcher.rewrite(IndexSearcher.java:582) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.rewrite(ContextIndexSearcher.java:116) | |
at org.apache.lucene.search.Query.weight(Query.java:100) | |
at org.apache.lucene.search.IndexSearcher.createWeight(IndexSearcher.java:652) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.createWeight(ContextIndexSearcher.java:126) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:291) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:279) | |
at org.elasticsearch.search.query.QueryPhase.execute(QueryPhase.java:211) | |
at org.elasticsearch.search.SearchService.executeFetchPhase(SearchService.java:280) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:501) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:492) | |
at org.elasticsearch.transport.netty.MessageChannelHandler$RequestHandler.run(MessageChannelHandler.java:236) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907) | |
at java.lang.Thread.run(Thread.java:619) | |
java.lang.NullPointerException | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.next(NumericRangeQuery.java:532) | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.<init>(NumericRangeQuery.java:476) | |
at org.apache.lucene.search.NumericRangeQuery.getEnum(NumericRangeQuery.java:303) | |
at org.apache.lucene.search.TermCollectingRewrite.collectTerms(TermCollectingRewrite.java:34) | |
at org.apache.lucene.search.ConstantScoreAutoRewrite.rewrite(ConstantScoreAutoRewrite.java:87) | |
at org.apache.lucene.search.MultiTermQuery$ConstantScoreAutoRewrite.rewrite(MultiTermQuery.java:215) | |
at org.apache.lucene.search.MultiTermQuery.rewrite(MultiTermQuery.java:291) | |
at org.apache.lucene.search.FilteredQuery.rewrite(FilteredQuery.java:173) | |
at org.apache.lucene.search.IndexSearcher.rewrite(IndexSearcher.java:582) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.rewrite(ContextIndexSearcher.java:116) | |
at org.apache.lucene.search.Query.weight(Query.java:100) | |
at org.apache.lucene.search.IndexSearcher.createWeight(IndexSearcher.java:652) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.createWeight(ContextIndexSearcher.java:126) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:291) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:279) | |
at org.elasticsearch.search.query.QueryPhase.execute(QueryPhase.java:211) | |
at org.elasticsearch.search.SearchService.executeFetchPhase(SearchService.java:280) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:501) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:492) | |
at org.elasticsearch.transport.netty.MessageChannelHandler$RequestHandler.run(MessageChannelHandler.java:236) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907) | |
at java.lang.Thread.run(Thread.java:619) | |
Patched version just for sebastian, look below for the stack trace, thanks! | |
java.lang.NullPointerException | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.next(NumericRangeQuery.java:532) | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.<init>(NumericRangeQuery.java:476) | |
at org.apache.lucene.search.NumericRangeQuery.getEnum(NumericRangeQuery.java:303) | |
at org.apache.lucene.search.TermCollectingRewrite.collectTerms(TermCollectingRewrite.java:34) | |
at org.apache.lucene.search.ConstantScoreAutoRewrite.rewrite(ConstantScoreAutoRewrite.java:87) | |
at org.apache.lucene.search.MultiTermQuery$ConstantScoreAutoRewrite.rewrite(MultiTermQuery.java:215) | |
at org.apache.lucene.search.MultiTermQuery.rewrite(MultiTermQuery.java:291) | |
at org.apache.lucene.search.FilteredQuery.rewrite(FilteredQuery.java:173) | |
at org.apache.lucene.search.IndexSearcher.rewrite(IndexSearcher.java:582) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.rewrite(ContextIndexSearcher.java:116) | |
at org.apache.lucene.search.Query.weight(Query.java:100) | |
at org.apache.lucene.search.IndexSearcher.createWeight(IndexSearcher.java:652) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.createWeight(ContextIndexSearcher.java:126) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:291) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:279) | |
at org.elasticsearch.search.query.QueryPhase.execute(QueryPhase.java:211) | |
at org.elasticsearch.search.SearchService.executeFetchPhase(SearchService.java:280) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:501) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:492) | |
at org.elasticsearch.transport.netty.MessageChannelHandler$RequestHandler.run(MessageChannelHandler.java:236) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907) | |
at java.lang.Thread.run(Thread.java:619) | |
Patched version just for sebastian, look below for the stack trace, thanks! | |
java.lang.NullPointerException | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.next(NumericRangeQuery.java:532) | |
at org.apache.lucene.search.NumericRangeQuery$NumericRangeTermEnum.<init>(NumericRangeQuery.java:476) | |
at org.apache.lucene.search.NumericRangeQuery.getEnum(NumericRangeQuery.java:303) | |
at org.apache.lucene.search.TermCollectingRewrite.collectTerms(TermCollectingRewrite.java:34) | |
at org.apache.lucene.search.ConstantScoreAutoRewrite.rewrite(ConstantScoreAutoRewrite.java:87) | |
at org.apache.lucene.search.MultiTermQuery$ConstantScoreAutoRewrite.rewrite(MultiTermQuery.java:215) | |
at org.apache.lucene.search.MultiTermQuery.rewrite(MultiTermQuery.java:291) | |
at org.apache.lucene.search.FilteredQuery.rewrite(FilteredQuery.java:173) | |
at org.apache.lucene.search.IndexSearcher.rewrite(IndexSearcher.java:582) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.rewrite(ContextIndexSearcher.java:116) | |
at org.apache.lucene.search.Query.weight(Query.java:100) | |
at org.apache.lucene.search.IndexSearcher.createWeight(IndexSearcher.java:652) | |
at org.elasticsearch.search.internal.ContextIndexSearcher.createWeight(ContextIndexSearcher.java:126) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:291) | |
at org.apache.lucene.search.IndexSearcher.search(IndexSearcher.java:279) | |
at org.elasticsearch.search.query.QueryPhase.execute(QueryPhase.java:211) | |
at org.elasticsearch.search.SearchService.executeFetchPhase(SearchService.java:280) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:501) | |
at org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryFetchTransportHandler.messageReceived(SearchServiceTransportAction.java:492) | |
at org.elasticsearch.transport.netty.MessageChannelHandler$RequestHandler.run(MessageChannelHandler.java:236) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907) | |
at java.lang.Thread.run(Thread.java:619) | |
[2011-05-21 17:26:37,425][INFO ][cluster.service ] [Kro] removed {[Scimitar][2k76Rsp-TwyVlzQsaC8eBg][inet[/10.0.0.1:9301]]{client=true, data=false},}, reason: zen-disco-node_failed([Scimitar][2k76Rsp-TwyVlzQsaC8eBg][inet[/10.0.0.1:9301]]{client=true, data=false}), reason transport disconnected (with verified connect) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package example; | |
import java.util.concurrent.ExecutionException; | |
import org.elasticsearch.action.ListenableActionFuture; | |
import org.elasticsearch.action.search.SearchOperationThreading; | |
import org.elasticsearch.action.search.SearchResponse; | |
import org.elasticsearch.action.search.SearchType; | |
import org.elasticsearch.client.Client; | |
import org.elasticsearch.client.action.search.SearchRequestBuilder; | |
import org.elasticsearch.common.unit.TimeValue; | |
import org.elasticsearch.index.query.xcontent.FilterBuilders; | |
import org.elasticsearch.index.query.xcontent.QueryBuilders; | |
import org.elasticsearch.index.query.xcontent.XContentFilterBuilder; | |
import org.elasticsearch.index.query.xcontent.XContentQueryBuilder; | |
import org.elasticsearch.node.Node; | |
import org.elasticsearch.node.NodeBuilder; | |
import org.elasticsearch.search.SearchHit; | |
public class SearchLoopExample { | |
private void launchSearch() throws InterruptedException, ExecutionException { | |
Node node = NodeBuilder.nodeBuilder().client(true).node(); | |
Client client = node.client(); | |
XContentFilterBuilder filterBuilder = FilterBuilders.termFilter("titulo", "whatever").cache(true); | |
XContentQueryBuilder randomQueryBuilder = QueryBuilders.rangeQuery( | |
"random") | |
.from(0) | |
.to(1) | |
.includeLower(true) | |
.includeUpper(true); | |
XContentQueryBuilder queryBuilder = QueryBuilders.filteredQuery(randomQueryBuilder, filterBuilder); | |
// SearchRequestBuilder searchRequestBuilder = client.prepareSearch("an-alias") | |
SearchRequestBuilder searchRequestBuilder = client.prepareSearch("index1") | |
.setOperationThreading(SearchOperationThreading.THREAD_PER_SHARD) | |
.setSearchType(SearchType.QUERY_AND_FETCH) | |
.setFrom(0) | |
.setSize(100) | |
.setQuery(queryBuilder) | |
.addField("title") | |
.setTimeout(TimeValue.timeValueSeconds(120)); | |
while(true) { | |
ListenableActionFuture<SearchResponse> future = searchRequestBuilder.execute(); | |
SearchResponse searchResponse = future.get(); | |
show(searchResponse); | |
} | |
// client.close(); | |
// node.stop(); | |
} | |
private void show(SearchResponse response) { | |
if (response.getHits().getTotalHits() > 0) { | |
System.out.println("------------- Response: -------------"); | |
for (SearchHit searchHit : response.hits()) { | |
System.out.println(searchHit); | |
} | |
} | |
} | |
public static void main(String[] args) throws InterruptedException, ExecutionException { | |
SearchLoopExample example = new SearchLoopExample(); | |
example.launchSearch(); | |
} | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2011-05-19 19:56:28,878][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: initializing ... | |
[2011-05-19 19:56:28,897][INFO ][plugins ] [Utgard-Loki] loaded [] | |
[2011-05-19 19:56:31,452][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: initialized | |
[2011-05-19 19:56:31,455][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: starting ... | |
[2011-05-19 19:56:31,615][INFO ][transport ] [Utgard-Loki] bound_address {inet[/0:0:0:0:0:0:0:0:9300]}, publish_address {inet[/10.0.0.1:9300]} | |
[2011-05-19 19:56:34,761][INFO ][cluster.service ] [Utgard-Loki] new_master [Utgard-Loki][RqBL-1pETpuksJqhNLai4A][inet[/10.0.0.1:9300]], reason: zen-disco-join (elected_as_master) | |
[2011-05-19 19:56:34,834][INFO ][discovery ] [Utgard-Loki] elasticsearch/RqBL-1pETpuksJqhNLai4A | |
[2011-05-19 19:56:34,877][INFO ][http ] [Utgard-Loki] bound_address {inet[/0:0:0:0:0:0:0:0:9200]}, publish_address {inet[/10.0.0.1:9200]} | |
[2011-05-19 19:56:34,881][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: started | |
[2011-05-19 19:56:34,899][INFO ][gateway ] [Utgard-Loki] recovered [0] indices into cluster_state | |
[2011-05-19 19:56:53,583][INFO ][cluster.service ] [Utgard-Loki] added {[Shathra][cghCPTZQQzSdTFv9fmgD5Q][inet[/10.0.0.1:9301]]{client=true, data=false},}, reason: zen-disco-receive(join from node[[Shathra][cghCPTZQQzSdTFv9fmgD5Q][inet[/10.0.0.1:9301]]{client=true, data=false}]) | |
[2011-05-19 19:56:54,226][INFO ][cluster.service ] [Utgard-Loki] removed {[Shathra][cghCPTZQQzSdTFv9fmgD5Q][inet[/10.0.0.1:9301]]{client=true, data=false},}, reason: zen-disco-node_failed([Shathra][cghCPTZQQzSdTFv9fmgD5Q][inet[/10.0.0.1:9301]]{client=true, data=false}), reason transport disconnected (with verified connect) | |
[2011-05-19 19:56:59,474][INFO ][cluster.metadata ] [Utgard-Loki] [index1] creating index, cause [auto(index api)], shards [5]/[1], mappings [p] | |
[2011-05-19 19:57:09,630][INFO ][cluster.service ] [Utgard-Loki] added {[Vapor][Qy90504YSkuETOrjLl51Mg][inet[/10.0.0.1:9301]]{client=true, data=false},}, reason: zen-disco-receive(join from node[[Vapor][Qy90504YSkuETOrjLl51Mg][inet[/10.0.0.1:9301]]{client=true, data=false}]) | |
[2011-05-19 19:57:11,536][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][2] took [7h]/[74ms], reclaimed [225.3mb], leaving [88.9mb] used, max [1.9gb] | |
[2011-05-19 19:57:13,538][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][3] took [2.5h]/[83ms], reclaimed [225.2mb], leaving [88.5mb] used, max [1.9gb] | |
[2011-05-19 19:57:15,544][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][4] took [2.4h]/[91ms], reclaimed [225.1mb], leaving [88.3mb] used, max [1.9gb] | |
[2011-05-19 19:57:17,545][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][5] took [2.4h]/[100ms], reclaimed [225.2mb], leaving [87.9mb] used, max [1.9gb] | |
[2011-05-19 19:57:19,547][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][6] took [3.1h]/[112ms], reclaimed [225.2mb], leaving [87.5mb] used, max [1.9gb] | |
[2011-05-19 19:57:21,548][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][7] took [1.7h]/[118ms], reclaimed [225.3mb], leaving [87.1mb] used, max [1.9gb] | |
[2011-05-19 19:57:23,550][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][8] took [2.4h]/[127ms], reclaimed [225.2mb], leaving [86.7mb] used, max [1.9gb] | |
[2011-05-19 19:57:24,551][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][9] took [2.1h]/[135ms], reclaimed [225.3mb], leaving [86.3mb] used, max [1.9gb] | |
[2011-05-19 19:57:26,553][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][10] took [2.1h]/[142ms], reclaimed [225.3mb], leaving [85.8mb] used, max [1.9gb] | |
[2011-05-19 19:57:27,553][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][11] took [2.3h]/[150ms], reclaimed [225.3mb], leaving [85.4mb] used, max [1.9gb] | |
[2011-05-19 19:57:29,555][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][12] took [2.7h]/[160ms], reclaimed [225.2mb], leaving [85mb] used, max [1.9gb] | |
[2011-05-19 19:57:30,556][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][13] took [2.8h]/[170ms], reclaimed [225.3mb], leaving [84.6mb] used, max [1.9gb] | |
[2011-05-19 19:57:32,557][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][14] took [2.2h]/[179ms], reclaimed [225.2mb], leaving [84.2mb] used, max [1.9gb] | |
[2011-05-19 19:57:33,558][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][15] took [1.6h]/[185ms], reclaimed [225mb], leaving [84mb] used, max [1.9gb] | |
[2011-05-19 19:57:34,558][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][16] took [2.4h]/[194ms], reclaimed [224.7mb], leaving [84.1mb] used, max [1.9gb] | |
[2011-05-19 19:57:36,560][INFO ][monitor.jvm ] [Utgard-Loki] [gc][Garbage collection optimized for throughput Young Collector][17] took [3h]/[205ms], reclaimed [224.8mb], leaving [84.2mb] used, max [1.9gb] | |
[2011-05-19 19:57:37,990][INFO ][cluster.service ] [Utgard-Loki] removed {[Vapor][Qy90504YSkuETOrjLl51Mg][inet[/10.0.0.1:9301]]{client=true, data=false},}, reason: zen-disco-node_failed([Vapor][Qy90504YSkuETOrjLl51Mg][inet[/10.0.0.1:9301]]{client=true, data=false}), reason transport disconnected (with verified connect) | |
[2011-05-19 19:57:52,920][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: stopping ... | |
[2011-05-19 19:57:53,032][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: stopped | |
[2011-05-19 19:57:53,032][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: closing ... | |
[2011-05-19 19:58:03,088][INFO ][node ] [Utgard-Loki] {elasticsearch/0.16.1}[9252]: closed |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
curl -XPUT 'http://localhost:9200/index1/p/1' -d ' | |
{ | |
"titulo" : "sony mp3", | |
"random" : "0.1" | |
} | |
' | |
curl -XPUT 'http://localhost:9200/index1/p/2' -d ' | |
{ | |
"titulo" : "panasonic mp3", | |
"random" : "0.2" | |
} | |
' | |
curl -XPUT 'http://localhost:9200/index1/p/3' -d ' | |
{ | |
"titulo" : "any mp3", | |
"random" : "0.3" | |
} | |
' | |
curl -XPUT 'http://localhost:9200/index1/p/4' -d ' | |
{ | |
"titulo" : "apple mp3", | |
"random" : "0.4" | |
} | |
' | |
curl -XPUT 'http://localhost:9200/index1/p/5' -d ' | |
{ | |
"titulo" : "rca mp3", | |
"random" : "0.5" | |
} | |
' | |
curl -XPOST 'http://localhost:9200/_refresh' | |
curl -XPOST 'http://localhost:9200/_flush' |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment