Skip to content

Instantly share code, notes, and snippets.

@sebaes

sebaes/ES_HOME\config\mappings\_default\p.json

Created May 18, 2011 18:36
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save sebaes/979208 to your computer and use it in GitHub Desktop.
Save sebaes/979208 to your computer and use it in GitHub Desktop.
Download ZIP
Loop causing the exception
Raw
ES_HOME\config\mappings\_default\p.json
{
"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"
}
}
}
}
Raw
log
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
Raw
new full exception
[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)
Raw
SearchLoopExample.java
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();
}
}
Raw
server.log
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
Raw
setup
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