# Class Cast when Sorting by geo\_distance? **URL:** \ **Category:** Elasticsearch\ **Created:** [August 11, 2011, 3:38pm UTC](https://discuss.elastic.co/t/class-cast-when-sorting-by-geo-distance/5127 "2011-08-11T15:38:17Z")\ **Posts on this page:** 4\ **Page:** 1
**Author:** ![Kodos\_2](https://avatars.discourse-cdn.com/v4/letter/k/54ee81/32.png) [@Kodos\_2](https://discuss.elastic.co/u/Kodos_2)\ **Post date:** [August 11, 2011, 3:38pm UTC](https://discuss.elastic.co/t/class-cast-when-sorting-by-geo-distance/5127/1 "2011-08-11T15:38:17Z")
I am prototyping an app that leverages ES' geospatial search capabilities, and I'm encountering an error when sorting results by geo\_distance. I'm hoping that I'm simply doing something incorrectly, but was looking for some direction. The ClassCast stacktrace is below, along with a unit test that replicates this behavior. Any guidance/advice would be greatly appreciated. --stack trace-- org.elasticsearch.action.search.SearchPhaseExecutionException: Failed to execute phase [query], total failure; shardFailures {RemoteTransportException[[Blazing Skull][inet[/10.0.1.5:9301]][search/ phase/query]]; nested: ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator $InnerSource cannot be cast to org.elasticsearch.index.field.data.FieldDataType $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator $InnerSource cannot be cast to org.elasticsearch.index.field.data.FieldDataType $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator $InnerSource cannot be cast to org.elasticsearch.index.field.data.FieldDataType $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator $InnerSource cannot be cast to org.elasticsearch.index.field.data.FieldDataType $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator $InnerSource cannot be cast to org.elasticsearch.index.field.data.FieldDataType $ExtendedFieldComparatorSource]; } at org.elasticsearch.action.search.type.TransportSearchTypeAction $BaseAsyncAction.onFirstPhaseResult(TransportSearchTypeAction.java: 257) at org.elasticsearch.action.search.type.TransportSearchTypeAction $BaseAsyncAction$3.onFailure(TransportSearchTypeAction.java:210) at org.elasticsearch.search.action.SearchServiceTransportAction $2.handleException(SearchServiceTransportAction.java:151) at org.elasticsearch.transport.netty.MessageChannelHandler.handleException(MessageChannelHandler.java: 158) at org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java: 149) at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java: 101) 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: 216) 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:886) at java.util.concurrent.ThreadPoolExecutor $Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:680) --end stack trace-- --unit test-- import static org.elasticsearch.index.query.QueryBuilders.termQuery; import static org.elasticsearch.node.NodeBuilder.nodeBuilder; import static org.elasticsearch.search.sort.SortBuilders.geoDistanceSort; import org.elasticsearch.action.count.CountResponse; import org.elasticsearch.client.Client; import org.elasticsearch.client.action.admin.indices.create.CreateIndexRequestBuilder; import org.elasticsearch.client.action.bulk.BulkRequestBuilder; import org.elasticsearch.client.action.search.SearchRequestBuilder; import org.elasticsearch.common.xcontent.XContentFactory; import org.elasticsearch.node.Node; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; public class SortTest { ``` private static Node node = null; private static final String INDEX = "sorttest"; private static final String TYPE = "testtype"; @Test public void testSort() { SearchRequestBuilder sb = node.client().prepareSearch(INDEX); sb.setQuery(termQuery("name", "kimchy")); sb.addSort(geoDistanceSort("location").point(43.12, -73.34)); sb.execute().actionGet(); } @BeforeClass public static void setup() throws Exception { node = nodeBuilder().client(true).node(); CreateIndexRequestBuilder requestBuilder = ``` node.client().admin().indices().prepareCreate(INDEX); requestBuilder.addMapping(TYPE, XContentFactory.jsonBuilder().startObject().startObject(TYPE).startObject("properties").startObject("location").field("type", "geo\_point").endObject().endObject().endObject()); requestBuilder.execute().actionGet(); if (loadData() == false) { throw new IllegalStateException("Loaded data not searchable?"); } } ``` private static boolean loadData() throws Exception { Client client = node.client(); BulkRequestBuilder b = node.client().prepareBulk(); b.add(client.prepareIndex(INDEX, TYPE, "1").setSource("{\"name\": ``` "kimchy","color": "red", "pin" : {"location" : "41.12,-71.34"}}")); b.add(client.prepareIndex(INDEX, TYPE, "2").setSource("{"name": "kimchy","color": "blue", "pin" : {"location" : "42.12,-72.34"}}")); b.execute().actionGet(); int execCount = 0; while (execCount \< 10) { CountResponse response = node.client().prepareCount(INDEX).setQuery(termQuery("name", "kimchy")).execute().actionGet(); if (response.count() \> 0) { return true; } else { Thread.currentThread().sleep(1000);//wait for docs to be indexed } } return false; } ``` @AfterClass public static void tearDown() throws Exception { ``` node.client().admin().indices().prepareDelete(INDEX).execute().actionGet(); } } --end unit test-- ---
**Author:** ![kimchy](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/kimchy/32/44952_2.png) [@kimchy](https://discuss.elastic.co/u/kimchy)\ **Post date:** [August 11, 2011, 8:26pm UTC](https://discuss.elastic.co/t/class-cast-when-sorting-by-geo-distance/5127/2 "2011-08-11T20:26:08Z")
Heya, Verified as a bug, opened an issue: [Failure to reduce geo distance sorting (class case exception) · Issue #1234 · elastic/elasticsearch · GitHub](https://github.com/elasticsearch/elasticsearch/issues/1234) (will be part of 0.17.5). One quick note, if you write tests, you don't have to write complex code to wait for the data to be searchable, just issue a refresh request and it will be searchable. -shay.banon On Thu, Aug 11, 2011 at 6:38 PM, Kodos [jake.meier@gmail.com](mailto:jake.meier@gmail.com) wrote: > I am prototyping an app that leverages ES' geospatial search > capabilities, and I'm encountering an error when sorting results by > geo\_distance. I'm hoping that I'm simply doing something incorrectly, > but was looking for some direction. The ClassCast stacktrace is > below, along with a unit test that replicates this behavior. > > Any guidance/advice would be greatly appreciated. > > --stack trace-- > org.elasticsearch.action.search.SearchPhaseExecutionException: Failed > to execute phase [query], total failure; shardFailures > {RemoteTransportException[[Blazing Skull][inet[/10.0.1.5:9301]][search/ > phase/query]]; nested: > > ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator > $InnerSource cannot be cast to > org.elasticsearch.index.field.data.FieldDataType > $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing > Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: > > ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator > $InnerSource cannot be cast to > org.elasticsearch.index.field.data.FieldDataType > $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing > Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: > > ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator > $InnerSource cannot be cast to > org.elasticsearch.index.field.data.FieldDataType > $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing > Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: > > ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator > $InnerSource cannot be cast to > org.elasticsearch.index.field.data.FieldDataType > $ExtendedFieldComparatorSource]; }{RemoteTransportException[[Blazing > Skull][inet[/10.0.1.5:9301]][search/phase/query]]; nested: > > ClassCastException[org.elasticsearch.index.search.geo.GeoDistanceDataComparator > $InnerSource cannot be cast to > org.elasticsearch.index.field.data.FieldDataType > $ExtendedFieldComparatorSource]; } > at org.elasticsearch.action.search.type.TransportSearchTypeAction > $BaseAsyncAction.onFirstPhaseResult(TransportSearchTypeAction.java: > 257) > at org.elasticsearch.action.search.type.TransportSearchTypeAction > $BaseAsyncAction$3.onFailure(TransportSearchTypeAction.java:210) > at org.elasticsearch.search.action.SearchServiceTransportAction > $2.handleException(SearchServiceTransportAction.java:151) > at > > org.elasticsearch.transport.netty.MessageChannelHandler.handleException(MessageChannelHandler.java: > 158) > at > > org.elasticsearch.transport.netty.MessageChannelHandler.handlerResponseError(MessageChannelHandler.java: > 149) > at > > org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(MessageChannelHandler.java: > 101) > 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: > 216) > 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:886) > at java.util.concurrent.ThreadPoolExecutor > $Worker.run(ThreadPoolExecutor.java:908) > at java.lang.Thread.run(Thread.java:680) > --end stack trace-- > > --unit test-- > import static org.elasticsearch.index.query.QueryBuilders.termQuery; > import static org.elasticsearch.node.NodeBuilder.nodeBuilder; > import static > org.elasticsearch.search.sort.SortBuilders.geoDistanceSort; > > import org.elasticsearch.action.count.CountResponse; > import org.elasticsearch.client.Client; > import > > org.elasticsearch.client.action.admin.indices.create.CreateIndexRequestBuilder; > import org.elasticsearch.client.action.bulk.BulkRequestBuilder; > import org.elasticsearch.client.action.search.SearchRequestBuilder; > import org.elasticsearch.common.xcontent.XContentFactory; > import org.elasticsearch.node.Node; > import org.junit.AfterClass; > import org.junit.BeforeClass; > import org.junit.Test; > > public class SortTest { > > ``` > private static Node node = null; > private static final String INDEX = "sorttest"; > private static final String TYPE = "testtype"; > > @Test > public void testSort() { > SearchRequestBuilder sb = > > ``` > > node.client().prepareSearch(INDEX); > sb.setQuery(termQuery("name", "kimchy")); > sb.addSort(geoDistanceSort("location").point(43.12, > -73.34)); > sb.execute().actionGet(); > } > > ``` > @BeforeClass > public static void setup() throws Exception { > node = nodeBuilder().client(true).node(); > CreateIndexRequestBuilder requestBuilder = > > ``` > > node.client().admin().indices().prepareCreate(INDEX); > requestBuilder.addMapping(TYPE, > > XContentFactory.jsonBuilder().startObject().startObject(TYPE).startObject("properties").startObject("location").field("type", > "geo\_point").endObject().endObject().endObject()); > requestBuilder.execute().actionGet(); > if (loadData() == false) { > throw new IllegalStateException("Loaded data not > searchable?"); > } > } > > ``` > private static boolean loadData() throws Exception { > Client client = node.client(); > BulkRequestBuilder b = node.client().prepareBulk(); > b.add(client.prepareIndex(INDEX, TYPE, > > ``` > > "1").setSource("{"name": > "kimchy","color": "red", "pin" : {"location" : > "41.12,-71.34"}}")); > b.add(client.prepareIndex(INDEX, TYPE, > "2").setSource("{"name": > "kimchy","color": "blue", "pin" : {"location" : > "42.12,-72.34"}}")); > b.execute().actionGet(); > int execCount = 0; > while (execCount \< 10) { > CountResponse response = > node.client().prepareCount(INDEX).setQuery(termQuery("name", > "kimchy")).execute().actionGet(); > if (response.count() \> 0) { > return true; > } else { > Thread.currentThread().sleep(1000);//wait > for docs to be indexed > } > } > return false; > } > > ``` > @AfterClass > public static void tearDown() throws Exception { > > ``` > > node.client().admin().indices().prepareDelete(INDEX).execute().actionGet(); > } > } > > --end unit test-- ---
**Author:** ![Kodos\_2](https://avatars.discourse-cdn.com/v4/letter/k/54ee81/32.png) [@Kodos\_2](https://discuss.elastic.co/u/Kodos_2)\ **Post date:** [August 11, 2011, 9:18pm UTC](https://discuss.elastic.co/t/class-cast-when-sorting-by-geo-distance/5127/3 "2011-08-11T21:18:52Z")
Brilliant. Thanks! ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 3:57am UTC](https://discuss.elastic.co/t/class-cast-when-sorting-by-geo-distance/5127/4 "2017-07-06T03:57:22Z")