Retrieving the cluster's state with indices filters

Hi folks,

I am currently updating my app to use the latest version of ES (0.90.3),
before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a filter
on indices :

val clusterState = client.admin().cluster().prepareState().setFilterIndices(
aliasName).execute().actionGet().getState()

The aliasName could be an existing index or not. It was perfectly working
on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is not an
existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.
java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(
DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297)
at java.lang.Thread.run(Thread.java:680)
Caused by: org.elasticsearch.indices.IndexMissingException: [en_us_old]missing
at org.elasticsearch.cluster.metadata.MetaData.concreteIndices(MetaData.
java:529)
at org.elasticsearch.cluster.metadata.MetaData.concreteIndicesIgnoreMissing
(MetaData.java:509)
at org.elasticsearch.action.admin.cluster.state.TransportClusterStateAction
.masterOperation(TransportClusterStateAction.java:101)
at org.elasticsearch.action.admin.cluster.state.TransportClusterStateAction
.masterOperation(TransportClusterStateAction.java:42)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$2.run(TransportMasterNodeOperationAction.
java:144)
at org.elasticsearch.common.util.concurrent.
MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.innerExecute(
TransportMasterNodeOperationAction.java:140)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(
TransportMasterNodeOperationAction.java:94)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(
TransportMasterNodeOperationAction.java:42)
at org.elasticsearch.action.support.TransportAction.execute(TransportAction
.java:61)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.execute(
TransportMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:266)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.netty.MessageChannelHandler.handleRequest(
MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.MessageChannelHandler.messageReceived(
MessageChannelHandler.java:108)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.
handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.
DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(
DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:296)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
unfoldAndFireMessageReceived(FrameDecoder.java:462)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
callDecode(FrameDecoder.java:443)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
messageReceived(FrameDecoder.java:303)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.
handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.
DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(
DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(
OpenChannelsHandler.java:74)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:559)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:268)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:255)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(
NioWorker.java:88)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.
process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.
run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(
AbstractNioWorker.java:90)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(
NioWorker.java:178)
at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(
ThreadRenamingRunnable.java:108)
at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(
DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.
java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier.baquier@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES (0.90.3),
before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepareState().
setFilterIndices(aliasName).execute().actionGet().getState()

The aliasName could be an existing index or not. It was perfectly working
on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is not an
existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.
java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(
DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297)
at java.lang.Thread.run(Thread.java:680)
Caused by: org.elasticsearch.indices.IndexMissingException: [en_us_old]missing
at org.elasticsearch.cluster.metadata.MetaData.concreteIndices(MetaData.
java:529)
at org.elasticsearch.cluster.metadata.MetaData.
concreteIndicesIgnoreMissing(MetaData.java:509)
at org.elasticsearch.action.admin.cluster.state.
TransportClusterStateAction.masterOperation(TransportClusterStateAction.
java:101)
at org.elasticsearch.action.admin.cluster.state.
TransportClusterStateAction.masterOperation(TransportClusterStateAction.
java:42)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$2.run(
TransportMasterNodeOperationAction.java:144)
at org.elasticsearch.common.util.concurrent.
MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.innerExecute(
TransportMasterNodeOperationAction.java:140)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(
TransportMasterNodeOperationAction.java:94)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(
TransportMasterNodeOperationAction.java:42)
at org.elasticsearch.action.support.TransportAction.execute(
TransportAction.java:61)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.execute(
TransportMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:266)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.netty.MessageChannelHandler.handleRequest(
MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.MessageChannelHandler.
messageReceived(MessageChannelHandler.java:108)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.
handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.
DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(
DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:296)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
unfoldAndFireMessageReceived(FrameDecoder.java:462)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
callDecode(FrameDecoder.java:443)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
messageReceived(FrameDecoder.java:303)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.
handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.
DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(
DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(
OpenChannelsHandler.java:74)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:559)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:268)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:255)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(
NioWorker.java:88)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.
process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.
run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.
run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(
NioWorker.java:178)
at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(
ThreadRenamingRunnable.java:108)
at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run
(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.
java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

https://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, <didier....@gmail.com <javascript:>>wrote:

Hi folks,

I am currently updating my app to use the latest version of ES (0.90.3),
before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepareState().
setFilterIndices(aliasName).execute().actionGet().getState()

The aliasName could be an existing index or not. It was perfectly working
on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is not an
existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.
java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(
DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297)
at java.lang.Thread.run(Thread.java:680)
Caused by: org.elasticsearch.indices.IndexMissingException: [en_us_old]missing
at org.elasticsearch.cluster.metadata.MetaData.concreteIndices(MetaData.
java:529)
at org.elasticsearch.cluster.metadata.MetaData.
concreteIndicesIgnoreMissing(MetaData.java:509)
at org.elasticsearch.action.admin.cluster.state.
TransportClusterStateAction.masterOperation(TransportClusterStateAction.
java:101)
at org.elasticsearch.action.admin.cluster.state.
TransportClusterStateAction.masterOperation(TransportClusterStateAction.
java:42)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$2.run(
TransportMasterNodeOperationAction.java:144)
at org.elasticsearch.common.util.concurrent.
MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.innerExecute(
TransportMasterNodeOperationAction.java:140)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(
TransportMasterNodeOperationAction.java:94)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(
TransportMasterNodeOperationAction.java:42)
at org.elasticsearch.action.support.TransportAction.execute(
TransportAction.java:61)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.execute(
TransportMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:266)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.netty.MessageChannelHandler.handleRequest
(MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.MessageChannelHandler.
messageReceived(MessageChannelHandler.java:108)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.
handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.
DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(
DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:296)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
unfoldAndFireMessageReceived(FrameDecoder.java:462)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
callDecode(FrameDecoder.java:443)
at org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.
messageReceived(FrameDecoder.java:303)
at org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.
handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.
DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(
DefaultChannelPipeline.java:791)
at org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(
OpenChannelsHandler.java:74)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.java:559)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:268)
at org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(
Channels.java:255)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(
NioWorker.java:88)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.
process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector
.run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.
run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(
NioWorker.java:178)
at org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(
ThreadRenamingRunnable.java:108)
at org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.
run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(
ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearc...@googlegroups.com <javascript:>.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

I missed that very important part of your original email. Perhaps I am
misunderstanding your usecase, but you want to have an alias on an index
that does not exist? Ailas information is stored in the index metadata and
aggregated from each index into the cluster state. No index = no alias.
An IndexMissingException sound appropriate.

Cheers,

Ivan

On Thu, Aug 22, 2013 at 10:04 AM, didier.baquier@gmail.com wrote:

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

https://github.com/elasticsearch/elasticsearch/
issues?direction=desc&labels=**v0.90.3&page=1&sort=updated&**state=closedhttps://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier....@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES (0.90.3),
before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepareState().
setFilterIndices(ali
asName).execute().actionGet().**getState()

The aliasName could be an existing index or not. It was perfectly
working on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is not
an existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccess
orImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAcce
ssorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMe
thodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.codehaus.mojo.exec.ExecJav
aMojo$1.run(ExecJavaMojo.java:297)
at java.lang.Thread.run(Thread.ja
va:680)
Caused by: org.elasticsearch.indices.IndexMissingException: [en_us_old
] missing
at org.elasticsearch.cluster.meta
data.MetaData.concreteIndices(**
MetaData.java:529)
at org.elasticsearch.cluster.metadata.MetaData.concreteIndicesI
gnoreMissing(MetaData.java:509**)
at org.elasticsearch.action.admin**.cluster.state.TransportCluste**
rStateAction.masterOperation(TransportClusterStateAction.java:101)
at org.elasticsearch.action.admin**.cluster.state.TransportCluste**
rStateAction.masterOperation(TransportClusterStateAction.java:42)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction$2.run(TransportMasterNodeOperationAction.java:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$
SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO**
perationAction.innerExecute(TransportMasterNodeOperationAction.java:
140)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.doExecute(TransportMasterNodeOperationAction.java:94)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO

perationAction.doExecute(TransportMasterNodeOperationAction.java:42)
at org.elasticsearch.action.suppo
rt.TransportAction.execute(Tra

nsportAction.java:61)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.execute(TransportMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:266)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO**
perationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.hand**
leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.mess**
ageReceived(MessageChannelHandler.java:108)
at org.elasticsearch.common.netty
.channel.SimpleChannelUpstream**
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipelin**
e$DefaultChannelHandlerContext**.sendUpstream(DefaultChannelPipeline.
java:791)
at org.elasticsearch.common.netty
.channel.Channels.fireMessageR**
eceived(Channels.java:296)
at org.elasticsearch.common.netty**.handler.codec.frame.FrameDecoder.
unfoldAndFireMessageReceiv
ed(FrameDecoder.java:462)
at org.elasticsearch.common.netty**.handler.codec.frame.FrameDecoder.
callDecode(FrameDecoder.ja
va:443)
at org.elasticsearch.common.netty**.handler.codec.frame.FrameDecoder.
messageReceived(FrameDecod
er.java:303)
at org.elasticsearch.common.netty**.channel.SimpleChannelUpstream**
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipelin**
e$DefaultChannelHandlerContext**.sendUpstream(DefaultChannelPipeline.
java:791)
at org.elasticsearch.common.netty
.OpenChannelsHandler.handleUps**
tream(OpenChannelsHandler.java**:74)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:559)
at org.elasticsearch.common.netty**.channel.Channels.fireMessageR**
eceived(Channels.java:268)
at org.elasticsearch.common.netty**.channel.Channels.fireMessageR**
eceived(Channels.java:255)
at org.elasticsearch.common.netty**.channel.socket.nio.NioWorker.read
(NioWorker.java:88)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi**
oWorker.process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi**
oSelector.run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi**
oWorker.run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty
.channel.socket.nio.NioWorker.run(
NioWorker.java:178)
at org.elasticsearch.common.netty
.util.ThreadRenamingRunnable.run(
ThreadRenamingRunnable.java
:108)
at org.elasticsearch.common.netty**.util.internal.DeadLockProofWo**
rker$1.run(DeadLockProofWorker**.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Threa
dPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
lExecutor.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.com.

For more options, visit https://groups.google.com/**groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

I just want to retrieve the list of the existing indices related to my
alias (could be 0 index). To do so, I am using the meta data of the cluster
state.

if you are familiar with scala, here is what I am doing ( it was working on
0.19.12)
val clusterState =
client.admin().cluster().prepareState().setFilterIndices(aliasName).execute().actionGet().getState()
Option(clusterState.metaData().aliases().get(aliasName)).map { _.keySet()
}.toList.flatten

if it is not possible to do something like that anymore, how can I test if
my alias is related to at least 1 index?

thanks for your help

Le jeudi 22 août 2013 10:16:21 UTC-7, Ivan Brusic a écrit :

I missed that very important part of your original email. Perhaps I am
misunderstanding your usecase, but you want to have an alias on an index
that does not exist? Ailas information is stored in the index metadata and
aggregated from each index into the cluster state. No index = no alias.
An IndexMissingException sound appropriate.

Cheers,

Ivan

On Thu, Aug 22, 2013 at 10:04 AM, <didier....@gmail.com <javascript:>>wrote:

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

https://github.com/elasticsearch/elasticsearch/
issues?direction=desc&labels=v0.90.3&page=1&sort=updated&
state=closedhttps://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier....@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES
(0.90.3), before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepareState().
setFilterIndices(ali
asName).execute().actionGet().**getState()

The aliasName could be an existing index or not. It was perfectly
working on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is not
an existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccess
orImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAcce
ssorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMe
thodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.codehaus.mojo.exec.ExecJav
aMojo$1.run(ExecJavaMojo.java:297
)
at java.lang.Thread.run(Thread.ja
va:680)
Caused by: org.elasticsearch.indices.IndexMissingException: [
en_us_old] missing
at org.elasticsearch.cluster.meta
data.MetaData.concreteIndices(**
MetaData.java:529)
at org.elasticsearch.cluster.metadata.MetaData.concreteIndicesI
gnoreMissing(MetaData.java:509**)
at org.elasticsearch.action.admin**.cluster.state.TransportCluste**
rStateAction.masterOperation(TransportClusterStateAction.java:101)
at org.elasticsearch.action.admin**.cluster.state.TransportCluste**
rStateAction.masterOperation(TransportClusterStateAction.java:42)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction$2.run(TransportMasterNodeOperationAction.java:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$
SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO**
perationAction.innerExecute(TransportMasterNodeOperationAction.java
:140)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.doExecute(TransportMasterNodeOperationAction.java:94
)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO

perationAction.doExecute(TransportMasterNodeOperationAction.java:42
)
at org.elasticsearch.action.suppo
rt.TransportAction.execute(Tra

nsportAction.java:61)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.execute(TransportMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:266)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO**
perationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.hand**
leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.mess**
ageReceived(MessageChannelHandler.java:108)
at org.elasticsearch.common.netty
.channel.SimpleChannelUpstream**
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipelin**
e$DefaultChannelHandlerContext**.sendUpstream(DefaultChannelPipeline.
java:791)
at org.elasticsearch.common.netty
.channel.Channels.fireMessageR**
eceived(Channels.java:296)
at org.elasticsearch.common.netty**.handler.codec.frame.FrameDecoder
.unfoldAndFireMessageReceiv
ed(FrameDecoder.java:462)
at org.elasticsearch.common.netty**.handler.codec.frame.FrameDecoder
.callDecode(FrameDecoder.ja
va:443)
at org.elasticsearch.common.netty**.handler.codec.frame.FrameDecoder
.messageReceived(FrameDecod
er.java:303)
at org.elasticsearch.common.netty**.channel.SimpleChannelUpstream**
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipelin**
e$DefaultChannelHandlerContext**.sendUpstream(DefaultChannelPipeline.
java:791)
at org.elasticsearch.common.netty
.OpenChannelsHandler.handleUps**
tream(OpenChannelsHandler.java**:74)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelP
ipeline.java:559)
at org.elasticsearch.common.netty**.channel.Channels.fireMessageR**
eceived(Channels.java:268)
at org.elasticsearch.common.netty**.channel.Channels.fireMessageR**
eceived(Channels.java:255)
at org.elasticsearch.common.netty**.channel.socket.nio.NioWorker.**
read(NioWorker.java:88)
at org.elasticsearch.common.netty**.channel.socket.nio.AbstractNi**
oWorker.process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi**
oSelector.run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi**
oWorker.run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty
.channel.socket.nio.NioWorker.run
(NioWorker.java:178)
at org.elasticsearch.common.netty
.util.ThreadRenamingRunnable.run(
ThreadRenamingRunnable.java
:108)
at org.elasticsearch.common.netty**.util.internal.DeadLockProofWo**
rker$1.run(DeadLockProofWorker**.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Threa
dPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoo
lExecutor.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.com.

For more options, visit https://groups.google.com/**groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearc...@googlegroups.com <javascript:>.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

"I just want to retrieve the list of the existing indices related to my
alias (could be 0 index)"

Not it can't. Each alias must have an index. Sounds like you are exploiting
a bug which has been fixed.

--
Ivan

On Thu, Aug 22, 2013 at 10:26 AM, didier.baquier@gmail.com wrote:

I just want to retrieve the list of the existing indices related to my
alias (could be 0 index). To do so, I am using the meta data of the cluster
state.

if you are familiar with scala, here is what I am doing ( it was working
on 0.19.12)
val clusterState =
client.admin().cluster().prepareState().setFilterIndices(aliasName).execute().actionGet().getState()
Option(clusterState.metaData().aliases().get(aliasName)).map { _.keySet()
}.toList.flatten

if it is not possible to do something like that anymore, how can I test if
my alias is related to at least 1 index?

thanks for your help

Le jeudi 22 août 2013 10:16:21 UTC-7, Ivan Brusic a écrit :

I missed that very important part of your original email. Perhaps I am
misunderstanding your usecase, but you want to have an alias on an index
that does not exist? Ailas information is stored in the index metadata and
aggregated from each index into the cluster state. No index = no alias.
An IndexMissingException sound appropriate.

Cheers,

Ivan

On Thu, Aug 22, 2013 at 10:04 AM, didier....@gmail.com wrote:

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

https://github.com/elasticsearch/elasticsearch/issues?
direction=desc&labels=**v0.90.3&**page=1&sort=updated&**state=**closedhttps://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier....@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES
(0.90.3), before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepareState().
setFilterIndices(ali
asName).execute().actionGet().****getState()

The aliasName could be an existing index or not. It was perfectly
working on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is not
an existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccess
orImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAcce**
**ssorImpl.java:39)
at sun.reflect.DelegatingMethodAc
cessorImpl.invoke(DelegatingMe**
thodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.codehaus.mojo.exec.ExecJav
aMojo$1.run(ExecJavaMojo.java:

297)
at java.lang.Thread.run(Thread.java:680)
Caused by: org.elasticsearch.indices.Inde
xMissingException: [
en_us_old] missing
at org.elasticsearch.cluster.meta****data.MetaData.concreteIndices(

MetaData.java:529)
at org.elasticsearch.cluster.meta****data.MetaData.concreteIndicesI

gnoreMissing(MetaData.java:509**)
at org.elasticsearch.action.admin****.cluster.state.TransportCluste**
rStateAction.masterOperation(TransportClusterStateAction.jav
a:101)
at org.elasticsearch.action.admin
**.cluster.state.TransportCluste**
rStateAction.masterOperation(TransportClusterStateAction.jav
a:42)
at org.elasticsearch.action.suppo****rt.master.TransportMasterNodeO

perationAction$2.run(TransportMasterNodeOperationAction.java
:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$SameT
hreadExecutorService.execute(M
oreExecutors.java:293)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO

perationAction.innerExecute(TransportMasterNodeOperationActi
on.java:140)
at org.elasticsearch.action.suppo****rt.master.TransportMasterNodeO

perationAction.doExecute(TransportMasterNodeOperationAction.
java:94)
at org.elasticsearch.action.suppo****rt.master.TransportMasterNodeO

perationAction.doExecute(TransportMasterNodeOperationAction.
java:42)
at org.elasticsearch.action.suppo****rt.TransportAction.execute(Tra

nsportAction.java:61)
at org.elasticsearch.action.suppo****rt.master.TransportMasterNodeO

perationAction.execute(TransportMasterNodeOperationAction.ja
va:89)
at org.elasticsearch.action.suppo****rt.master.TransportMasterNodeO

perationAction$TransportHandler.messageReceived(TransportMas**
terNodeOperationAction.java:266)
at org.elasticsearch.action.support.master.TransportMasterNodeO**
perationAction$TransportHandler.messageReceived(TransportMas**
terNodeOperationAction.java:250)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.hand**
leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.mess

ageReceived(MessageChannelHandler.java:108)
at org.elasticsearch.common.netty
.channel.SimpleChannelUpstream

Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipelin

e.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipelin

e$DefaultChannelHandlerContext**.sendUpstream(DefaultChannelPi****
peline.java:791)
at org.elasticsearch.common.netty****.channel.Channels.fireMessageR**
eceived(Channels.java:296)
at org.elasticsearch.common.netty
**.handler.codec.frame.FrameDeco**
der.unfoldAndFireMessageReceived(FrameDecoder.java:462)
at org.elasticsearch.common.netty
.handler.codec.frame.FrameDeco

der.callDecode(FrameDecoder.java:443)
at org.elasticsearch.common.netty
.handler.codec.frame.FrameDeco

der.messageReceived(FrameDecoder.java:303)
at org.elasticsearch.common.netty
.channel.SimpleChannelUpstream

Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipelin

e.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipelin

e$DefaultChannelHandlerContext**.sendUpstream(DefaultChannelPi****
peline.java:791)
at org.elasticsearch.common.netty****.OpenChannelsHandler.handleUps**
tream(OpenChannelsHandler.java**:74)
at org.elasticsearch.common.netty****.channel.DefaultChannelPipelin**
e.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty
.channel.DefaultChannelPipelin

e.sendUpstream(DefaultChannelPipeline.java:559)
at org.elasticsearch.common.netty
.channel.Channels.fireMessageR

eceived(Channels.java:268)
at org.elasticsearch.common.netty
**.channel.Channels.fireMessageR**
eceived(Channels.java:255)
at org.elasticsearch.common.netty
**.channel.socket.nio.NioWorker.**
read(NioWorker.java:88)
at org.elasticsearch.common.netty
**.channel.socket.nio.AbstractNi**
oWorker.process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi

oSelector.run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty
.channel.socket.nio.AbstractNi

oWorker.run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty
.channel.socket.nio.NioWorker.

run(NioWorker.java:178)
at org.elasticsearch.common.netty
**.util.ThreadRenamingRunnable.r**
un(ThreadRenamingRunnable.java**:108)
at org.elasticsearch.common.netty****.util.internal.DeadLockProofWo**
rker$1.run(DeadLockProofWorker**.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Threa**
**dPoolExecutor.java:895)
at java.util.concurrent.ThreadPoo
lExecutor$Worker.run(ThreadPoo**
**lExecutor.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.**com.

For more options, visit https://groups.google.com/groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.com.
For more options, visit https://groups.google.com/**groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

awww!

so there is no way to test if an alias is related to an index? is it like
testing the existence of an index at the end right? is there another way to
do something like that?

Le jeudi 22 août 2013 10:40:08 UTC-7, Ivan Brusic a écrit :

"I just want to retrieve the list of the existing indices related to my
alias (could be 0 index)"

Not it can't. Each alias must have an index. Sounds like you are
exploiting a bug which has been fixed.

--
Ivan

On Thu, Aug 22, 2013 at 10:26 AM, <didier....@gmail.com <javascript:>>wrote:

I just want to retrieve the list of the existing indices related to my
alias (could be 0 index). To do so, I am using the meta data of the cluster
state.

if you are familiar with scala, here is what I am doing ( it was working
on 0.19.12)
val clusterState =
client.admin().cluster().prepareState().setFilterIndices(aliasName).execute().actionGet().getState()
Option(clusterState.metaData().aliases().get(aliasName)).map { _.keySet()
}.toList.flatten

if it is not possible to do something like that anymore, how can I test
if my alias is related to at least 1 index?

thanks for your help

Le jeudi 22 août 2013 10:16:21 UTC-7, Ivan Brusic a écrit :

I missed that very important part of your original email. Perhaps I am
misunderstanding your usecase, but you want to have an alias on an index
that does not exist? Ailas information is stored in the index metadata and
aggregated from each index into the cluster state. No index = no alias.
An IndexMissingException sound appropriate.

Cheers,

Ivan

On Thu, Aug 22, 2013 at 10:04 AM, didier....@gmail.com wrote:

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

https://github.com/elasticsearch/elasticsearch/issues?
direction=desc&labels=**v0.90.3&**page=1&sort=updated&**state=**closedhttps://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier....@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES
(0.90.3), before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepareState().
setFilterIndices(ali
asName).execute().actionGet().****getState()

The aliasName could be an existing index or not. It was perfectly
working on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is
not an existing index.

java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccess
orImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAcce
ssorImpl.java:39)
at sun.reflect.DelegatingMethodAc
cessorImpl.invoke(DelegatingMe

thodAccessorImpl.java:25)
at java.lang.reflect.Method.invok
e(Method.java:597)
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:
297)
at java.lang.Thread.run(Thread.ja
va:680)
Caused by: org.elasticsearch.indices.Inde
xMissingException: [
en_us_old] missing
at org.elasticsearch.cluster.meta
data.MetaData.concreteIndices(
MetaData.java:529)
at org.elasticsearch.cluster.meta
data.MetaData.concreteIndicesI*
gnoreMissing(MetaData.java:509*)
at org.elasticsearch.action.admin****.cluster.state.TransportCluste*
rStateAction.masterOperation(TransportClusterStateAction.jav**
a:101)
at org.elasticsearch.action.admin
*.cluster.state.TransportCluste*
rStateAction.masterOperation(TransportClusterStateAction.jav**
a:42)
at org.elasticsearch.action.suppo
*rt.master.TransportMasterNodeO
perationAction$2.run(Transport
MasterNodeOperationAction.java
:144)
at org.elasticsearch.common.util.**concurrent.MoreExecutors$
SameT
hreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.innerExecute(Tr
ansportMasterNodeOperationActi**
**on.java:140)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO
perationAction.doExecute(Trans
portMasterNodeOperationAction.**
java:94)
at org.elasticsearch.action.suppo**rt.master.TransportMasterNodeO
perationAction.doExecute(Trans
portMasterNodeOperationAction.

java:42)
at org.elasticsearch.action.support.TransportAction.execute(Tra
nsportAction.java:61)
at org.elasticsearch.action.suppo
rt.master.TransportMasterNodeO

perationAction.execute(Transpo
rtMasterNodeOperationAction.ja

va:89)
at org.elasticsearch.action.suppo***rt.master.TransportMasterNodeO
perationAction$TransportHandler.messageReceived(TransportMas
terNodeOperationAction.java:26
6)
at org.elasticsearch.action.suppo***rt.master.TransportMasterNodeO
perationAction$TransportHandler.messageReceived(TransportMas
terNodeOperationAction.java:25
0)
at org.elasticsearch.transport.netty.MessageChannelHandler.hand
leRequest(MessageChannelHandle
r.java:211)
at org.elasticsearch.transport.ne
tty.MessageChannelHandler.mess
ageReceived(MessageChannelHand
ler.java:108)
at org.elasticsearch.common.netty****.channel.SimpleChannelUpstream*
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
***.channel.DefaultChannelPipelin*
e.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty
***.channel.DefaultChannelPipelin*
e$DefaultChannelHandlerContext*.sendUpstream(DefaultChannelPi**
peline.java:791)
at org.elasticsearch.common.netty
**.channel.Channels.fireMessageR*
eceived(Channels.java:296)
at org.elasticsearch.common.netty
*.handler.codec.frame.FrameDeco*
der.unfoldAndFireMessageReceived(FrameDecoder.java:462)
at org.elasticsearch.common.netty
***.handler.codec.frame.FrameDeco*
der.callDecode(FrameDecoder.java:443)
at org.elasticsearch.common.netty
***.handler.codec.frame.FrameDeco*
der.messageReceived(FrameDecoder.java:303)
at org.elasticsearch.common.netty
***.channel.SimpleChannelUpstream*
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty
***.channel.DefaultChannelPipelin*
e.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty
***.channel.DefaultChannelPipelin*
e$DefaultChannelHandlerContext*.sendUpstream(DefaultChannelPi**
peline.java:791)
at org.elasticsearch.common.netty
**.OpenChannelsHandler.handleUps*
tream(OpenChannelsHandler.java*:74)
at org.elasticsearch.common.netty****.channel.DefaultChannelPipelin*
e.sendUpstream(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty
***.channel.DefaultChannelPipelin*
e.sendUpstream(DefaultChannelPipeline.java:559)
at org.elasticsearch.common.netty
***.channel.Channels.fireMessageR*
eceived(Channels.java:268)
at org.elasticsearch.common.netty
*.channel.Channels.fireMessageR*
eceived(Channels.java:255)
at org.elasticsearch.common.netty
*.channel.socket.nio.NioWorker.*
read(NioWorker.java:88)
at org.elasticsearch.common.netty
*.channel.socket.nio.AbstractNi*
oWorker.process(AbstractNioWorker.java:109)
at org.elasticsearch.common.netty
***.channel.socket.nio.AbstractNi*
oSelector.run(AbstractNioSelector.java:312)
at org.elasticsearch.common.netty
***.channel.socket.nio.AbstractNi*
oWorker.run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty
.channel.socket.nio.NioWorker.

run(NioWorker.java:178)
at org.elasticsearch.common.netty
.util.ThreadRenamingRunnable.r

un(ThreadRenamingRunnable.java*:108)
at org.elasticsearch.common.netty****.util.internal.DeadLockProofWo*
rker$1.run(DeadLockProofWorker*.java:42)
at java.util.concurrent.ThreadPoo*lExecutor$Worker.runTask(Threa
dPoolExecutor.java:895)
at java.util.concurrent.ThreadPoo
lExecutor$Worker.run(ThreadPoo

***lExecutor.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it,
send an email to elasticsearc...@**googlegroups.**com.

For more options, visit https://groups.google.com/groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.com.
For more options, visit https://groups.google.com/**groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearc...@googlegroups.com <javascript:>.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

You can gather all the aliases and see if the one you are interested in
exists.

// in Java so that you can see the return types
ImmutableMap<String, ImmutableMap<String, AliasMetaData>> aliases =
client.admin().cluster().state(new
ClusterStateRequest()).actionGet().getState().getMetaData().aliases();

ImmutableMap<String, AliasMetaData> pAlias = aliases.get(aliasName);

On Thu, Aug 22, 2013 at 10:58 AM, didier.baquier@gmail.com wrote:

awww!

so there is no way to test if an alias is related to an index? is it like
testing the existence of an index at the end right? is there another way to
do something like that?

Le jeudi 22 août 2013 10:40:08 UTC-7, Ivan Brusic a écrit :

"I just want to retrieve the list of the existing indices related to my
alias (could be 0 index)"

Not it can't. Each alias must have an index. Sounds like you are
exploiting a bug which has been fixed.

--
Ivan

On Thu, Aug 22, 2013 at 10:26 AM, didier....@gmail.com wrote:

I just want to retrieve the list of the existing indices related to my
alias (could be 0 index). To do so, I am using the meta data of the cluster
state.

if you are familiar with scala, here is what I am doing ( it was working
on 0.19.12)
val clusterState = client.admin().cluster().prepareState().
setFilterIndices(aliasName).**execute().actionGet().getState()
Option(clusterState.metaData()
.aliases().get(aliasName)).map {
_.keySet() }.toList.flatten

if it is not possible to do something like that anymore, how can I test
if my alias is related to at least 1 index?

thanks for your help

Le jeudi 22 août 2013 10:16:21 UTC-7, Ivan Brusic a écrit :

I missed that very important part of your original email. Perhaps I am
misunderstanding your usecase, but you want to have an alias on an index
that does not exist? Ailas information is stored in the index metadata and
aggregated from each index into the cluster state. No index = no alias.
An IndexMissingException sound appropriate.

Cheers,

Ivan

On Thu, Aug 22, 2013 at 10:04 AM, didier....@gmail.com wrote:

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is a
regression bug, one of these issues might have affected it:

https://github.com/elasticsear****ch/elasticsearch/issues?
direct
ion=desc&labels=**v0.90.3&**page=**1&sort=updated&state=
closedhttps://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier....@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES
(0.90.3), before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with a
filter on indices :

val clusterState = client.admin().cluster().prepa******reState().
setFilterIndices(ali******asName).execute().actionGet().******
getState()

The aliasName could be an existing index or not. It was perfectly
working on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is
not an existing index.

java.lang.reflect.InvocationTa******rgetException
at sun.reflect.NativeMethodAccess******orImpl.invoke0(Native Method
)
at sun.reflect.NativeMethodAccess******orImpl.invoke(
NativeMethodAcce******ssorImpl.java:39)
at sun.reflect.DelegatingMethodAc******cessorImpl.invoke(
DelegatingMe******thodAccessorImpl.java:25)
at java.lang.reflect.Method.invok******e(Method.java:597)
at org.codehaus.mojo.exec.ExecJav******aMojo$1.run(ExecJavaMojo.
java:297)
at java.lang.Thread.run(Thread.ja******va:680)
Caused by: org.elasticsearch.indices.Inde******xMissingException: [
en_us_old] missing
at org.elasticsearch.cluster.meta******data.MetaData.
concreteIndices(MetaData.java:529)
at org.elasticsearch.cluster.meta******data.MetaData.
concreteIndicesI******gnoreMissing(MetaData.java:509
)
at org.elasticsearch.action.admin
.cluster.state.
TransportCluste******rStateAction.masterOperation(T******
ransportClusterStateAction.jav******a:101)
at org.elasticsearch.action.admin******.cluster.state.
TransportCluste******rStateAction.masterOperation(T******
ransportClusterStateAction.jav******a:42)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeOperationAction$2.run(Transport******
MasterNodeOperationAction.java******:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$
SameT
hreadExecutorService.exec
ute(M
oreExecutors.java:293)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.innerExecute(Tr******
ansportMasterNodeOperationActi******on.java:140)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.doExecute(Trans******
portMasterNodeOperationAction.java:94)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.doExecute(Trans

portMasterNodeOperationAction.java:42)
at org.elasticsearch.action.suppo******rt.TransportAction.execute(
Tra******nsportAction.java:61)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.execute(Transpo

rtMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceiv
ed(TransportMas
terNodeOperatio
nAction.java:26

6)
at org.elasticsearch.action.suppo
rt.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceiv
ed(TransportMas
terNodeOperatio
nAction.java:25

0)
at org.elasticsearch.transport.ne
****tty.MessageChannelHandler.
hand******leRequest(MessageChannelHandle******r.java:211)
at org.elasticsearch.transport.ne******tty.MessageChannelHandler.
mess******ageReceived(MessageChannelHand******ler.java:108)
at org.elasticsearch.common.netty******.channel.
SimpleChannelUpstream******Handler.handleUpstream(SimpleC******
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e$DefaultChannelHandlerContext******.
sendUpstream(DefaultChannelPi******peline.java:791)
at org.elasticsearch.common.netty******.channel.Channels.
fireMessageR******eceived(Channels.java:296)
at org.elasticsearch.common.netty******.handler.codec.frame.
FrameDeco******der.unfoldAndFireMessageReceiv******ed(FrameDecoder.
java:462)
at org.elasticsearch.common.netty******.handler.codec.frame.
FrameDeco******der.callDecode(FrameDecoder.ja******va:443)
at org.elasticsearch.common.netty******.handler.codec.frame.
FrameDeco******der.messageReceived(FrameDecod******er.java:303)
at org.elasticsearch.common.netty******.channel.
SimpleChannelUpstream******Handler.handleUpstream(SimpleC******
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e$DefaultChannelHandlerContext******.
sendUpstream(DefaultChannelPi******peline.java:791)
at org.elasticsearch.common.netty******.OpenChannelsHandler.
handleUps******tream(OpenChannelsHandler.java******:74)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:559)
at org.elasticsearch.common.netty******.channel.Channels.
fireMessageR******eceived(Channels.java:268)
at org.elasticsearch.common.netty******.channel.Channels.
fireMessageR******eceived(Channels.java:255)
at org.elasticsearch.common.netty******.channel.socket.nio.
NioWorker.read(NioWorker.java:88)
at org.elasticsearch.common.netty
.channel.socket.nio.
AbstractNi******oWorker.process(AbstractNioWor******ker.java:109)
at org.elasticsearch.common.netty******.channel.socket.nio.
AbstractNi******oSelector.run(AbstractNioSelec******tor.java:312)
at org.elasticsearch.common.netty******.channel.socket.nio.
AbstractNi******oWorker.run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty
.channel.socket.nio.
NioWorker.run(NioWorker.java:178)
at org.elasticsearch.common.netty
.util.ThreadRenamingRunnable
.r******un(ThreadRenamingRunnable.java******:108)
at org.elasticsearch.common.netty******.util.internal.
DeadLockProofWo******rker$1.run(DeadLockProofWorker******.java:42)
at java.util.concurrent.ThreadPoo******lExecutor$Worker.runTask(
Threa******dPoolExecutor.java:895)
at java.util.concurrent.ThreadPoo******lExecutor$Worker.run(
ThreadPoo******lExecutor.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it,
send an email to elasticsearc...@**googlegroups.com.

For more options, visit https://groups.google.com/grou**
ps/opt_out https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.**com.
For more options, visit https://groups.google.com/groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.com.
For more options, visit https://groups.google.com/**groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.

Great! I am gonna try that solution today, I'll give you some feedbacks.

thanks

Le jeudi 22 août 2013 11:02:56 UTC-7, Ivan Brusic a écrit :

You can gather all the aliases and see if the one you are interested in
exists.

// in Java so that you can see the return types
ImmutableMap<String, ImmutableMap<String, AliasMetaData>> aliases =
client.admin().cluster().state(new
ClusterStateRequest()).actionGet().getState().getMetaData().aliases();

ImmutableMap<String, AliasMetaData> pAlias = aliases.get(aliasName);

On Thu, Aug 22, 2013 at 10:58 AM, <didier....@gmail.com <javascript:>>wrote:

awww!

so there is no way to test if an alias is related to an index? is it like
testing the existence of an index at the end right? is there another way to
do something like that?

Le jeudi 22 août 2013 10:40:08 UTC-7, Ivan Brusic a écrit :

"I just want to retrieve the list of the existing indices related to my
alias (could be 0 index)"

Not it can't. Each alias must have an index. Sounds like you are
exploiting a bug which has been fixed.

--
Ivan

On Thu, Aug 22, 2013 at 10:26 AM, didier....@gmail.com wrote:

I just want to retrieve the list of the existing indices related to my
alias (could be 0 index). To do so, I am using the meta data of the cluster
state.

if you are familiar with scala, here is what I am doing ( it was
working on 0.19.12)
val clusterState = client.admin().cluster().prepareState().
setFilterIndices(aliasName).**execute().actionGet().getState()
Option(clusterState.metaData()
.aliases().get(aliasName)).map {
_.keySet() }.toList.flatten

if it is not possible to do something like that anymore, how can I test
if my alias is related to at least 1 index?

thanks for your help

Le jeudi 22 août 2013 10:16:21 UTC-7, Ivan Brusic a écrit :

I missed that very important part of your original email. Perhaps I am
misunderstanding your usecase, but you want to have an alias on an index
that does not exist? Ailas information is stored in the index metadata and
aggregated from each index into the cluster state. No index = no alias.
An IndexMissingException sound appropriate.

Cheers,

Ivan

On Thu, Aug 22, 2013 at 10:04 AM, didier....@gmail.com wrote:

Thanks Ivan,

I presume that you tried with a non-existing index?

is someone can try on 0.90.3? could be a great help!

thanks

Le jeudi 22 août 2013 10:00:18 UTC-7, Ivan Brusic a écrit :

I run some similar code and it works fine on 0.90.2. If it truly is
a regression bug, one of these issues might have affected it:

https://github.com/elasticsear****ch/elasticsearch/issues?
direct
ion=desc&labels=**v0.90.3&**page=**1&sort=updated&state=
closedhttps://github.com/elasticsearch/elasticsearch/issues?direction=desc&labels=v0.90.3&page=1&sort=updated&state=closed

Cheers,

Ivan

On Wed, Aug 21, 2013 at 1:56 PM, didier....@gmail.com wrote:

Hi folks,

I am currently updating my app to use the latest version of ES
(0.90.3), before I was using (0.19.12).

I had the following line to retrieve the state of the cluster with
a filter on indices :

val clusterState = client.admin().cluster().prepa******reState().
setFilterIndices(ali******asName).execute().actionGet().******
getState()

The aliasName could be an existing index or not. It was perfectly
working on 0.19.12.

Now the actionGet() method throws an exception if the aliasName is
not an existing index.

java.lang.reflect.InvocationTa******rgetException
at sun.reflect.NativeMethodAccess******orImpl.invoke0(Native
Method)
at sun.reflect.NativeMethodAccess******orImpl.invoke(
NativeMethodAcce******ssorImpl.java:39)
at sun.reflect.DelegatingMethodAc******cessorImpl.invoke(
DelegatingMe******thodAccessorImpl.java:25)
at java.lang.reflect.Method.invok******e(Method.java:597)
at org.codehaus.mojo.exec.ExecJav******aMojo$1.run(ExecJavaMojo.
java:297)
at java.lang.Thread.run(Thread.ja******va:680)
Caused by: org.elasticsearch.indices.Inde******xMissingException: [
en_us_old] missing
at org.elasticsearch.cluster.meta******data.MetaData.
concreteIndices(MetaData.java:529)
at org.elasticsearch.cluster.meta******data.MetaData.
concreteIndicesI******gnoreMissing(MetaData.java:509
)
at org.elasticsearch.action.admin
.cluster.state.
TransportCluste******rStateAction.masterOperation(T******
ransportClusterStateAction.jav******a:101)
at org.elasticsearch.action.admin******.cluster.state.
TransportCluste******rStateAction.masterOperation(T******
ransportClusterStateAction.jav******a:42)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeOperationAction$2.run(Transport******
MasterNodeOperationAction.java******:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$
SameT
hreadExecutorService.exec
ute(M
oreExecutors.java:293)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.innerExecute(Tr******
ansportMasterNodeOperationActi******on.java:140)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.doExecute(Trans******
portMasterNodeOperationAction.java:94)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.doExecute(Trans

portMasterNodeOperationAction.java:42)
at org.elasticsearch.action.suppo******rt.TransportAction.execute(
Tra******nsportAction.java:61)
at org.elasticsearch.action.suppo******rt.master.
TransportMasterNodeO******perationAction.execute(Transpo

rtMasterNodeOperationAction.ja*****va:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceiv
ed(TransportMas
terNodeOperatio
nAction.java:26

6)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceiv
ed(TransportMas
terNodeOperatio
nAction.java:25

0)
at org.elasticsearch.transport.ne******tty.MessageChannelHandler.
hand******leRequest(MessageChannelHandle******r.java:211)
at org.elasticsearch.transport.ne******tty.MessageChannelHandler.
mess******ageReceived(MessageChannelHand******ler.java:108)
at org.elasticsearch.common.netty
*.channel.
SimpleChannelUpstream******Handler.handleUpstream(SimpleC******
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e$DefaultChannelHandlerContext******.
sendUpstream(DefaultChannelPi******peline.java:791)
at org.elasticsearch.common.netty******.channel.Channels.
fireMessageR******eceived(Channels.java:296)
at org.elasticsearch.common.netty******.handler.codec.frame.
FrameDeco******der.unfoldAndFireMessageReceiv******ed(FrameDecoder.
java:462)
at org.elasticsearch.common.netty******.handler.codec.frame.
FrameDeco******der.callDecode(FrameDecoder.ja******va:443)
at org.elasticsearch.common.netty******.handler.codec.frame.
FrameDeco******der.messageReceived(FrameDecod******er.java:303)
at org.elasticsearch.common.netty******.channel.
SimpleChannelUpstream******Handler.handleUpstream(SimpleC******
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e$DefaultChannelHandlerContext******.
sendUpstream(DefaultChannelPi******peline.java:791)
at org.elasticsearch.common.netty******.OpenChannelsHandler.
handleUps******tream(OpenChannelsHandler.java******:74)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipelin******e.sendUpstream(DefaultChannelP******
ipeline.java:559)
at org.elasticsearch.common.netty******.channel.Channels.
fireMessageR******eceived(Channels.java:268)
at org.elasticsearch.common.netty******.channel.Channels.
fireMessageR******eceived(Channels.java:255)
at org.elasticsearch.common.netty******.channel.socket.nio.
NioWorker.read(NioWorker.java:88)
at org.elasticsearch.common.netty
.channel.socket.nio.
AbstractNi******oWorker.process(AbstractNioWor******ker.java:109)
at org.elasticsearch.common.netty******.channel.socket.nio.
AbstractNi******oSelector.run(AbstractNioSelec******tor.java:312)
at org.elasticsearch.common.netty******.channel.socket.nio.
AbstractNi******oWorker.run(AbstractNioWorker.java:90)
at org.elasticsearch.common.netty
.channel.socket.nio.
NioWorker.run(NioWorker.java:178)
at org.elasticsearch.common.netty
.util.
ThreadRenamingRunnable.r******un(ThreadRenamingRunnable.java******:
108)
at org.elasticsearch.common.netty******.util.internal.
DeadLockProofWo******rker$1.run(DeadLockProofWorker******.java:42)
at java.util.concurrent.ThreadPoo******lExecutor$Worker.runTask(
Threa******dPoolExecutor.java:895)
at java.util.concurrent.ThreadPoo******lExecutor$Worker.run(
ThreadPoo******lExecutor.java:918)
... 1 more

Could you please help me on that issue?

thanks guys

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it,
send an email to elasticsearc...@**googlegroups.com.

For more options, visit https://groups.google.com/grou**
ps/opt_out https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it,
send an email to elasticsearc...@**googlegroups.**com.
For more options, visit https://groups.google.com/groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google
Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send
an email to elasticsearc...@**googlegroups.com.
For more options, visit https://groups.google.com/**groups/opt_outhttps://groups.google.com/groups/opt_out
.

--
You received this message because you are subscribed to the Google Groups
"elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an
email to elasticsearc...@googlegroups.com <javascript:>.
For more options, visit https://groups.google.com/groups/opt_out.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.