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
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
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.
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.
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(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.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.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.support.master.TransportMasterNodeO**
perationAction.innerExecute(TransportMasterNodeOperationAction.java:
140)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.doExecute(TransportMasterNodeOperationAction.java:94)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.doExecute(TransportMasterNodeOperationAction.java:42)
at org.elasticsearch.action.support.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.support.master.TransportMasterNodeO**
perationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.netty.MessageChannelHandler.hand**
leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.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(DefaultChannelPipeline.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.
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.SimpleChannelUpstream**
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.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(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipeline.
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.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.
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.
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(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.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.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.support.master.TransportMasterNodeO**
perationAction.innerExecute(TransportMasterNodeOperationAction.java
:140)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.doExecute(TransportMasterNodeOperationAction.java:94
)
at org.elasticsearch.action.support.master.TransportMasterNodeO
perationAction.doExecute(TransportMasterNodeOperationAction.java:42
)
at org.elasticsearch.action.support.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.support.master.TransportMasterNodeO**
perationAction$TransportHandler.messageReceived(
TransportMasterNodeOperationAction.java:250)
at org.elasticsearch.transport.netty.MessageChannelHandler.hand**
leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.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(DefaultChannelPipeline.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
.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.SimpleChannelUpstream**
Handler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty.channel.DefaultChannelPipeline.
sendUpstream(DefaultChannelPipeline.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(DefaultChannelPipeline.java:564)
at org.elasticsearch.common.netty**.channel.DefaultChannelPipeline.
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.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.
--
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.
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.
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(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.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.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(MoreExecutors.java:293)
at org.elasticsearch.action.support.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.netty.MessageChannelHandler.hand** leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.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.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.
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.
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.
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(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.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.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.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.support.master.TransportMasterNodeO perationAction.innerExecute(TransportMasterNodeOperationActi**
**on.java:140)
at org.elasticsearch.action.support.master.TransportMasterNodeO perationAction.doExecute(TransportMasterNodeOperationAction.**
**java:94)
at org.elasticsearch.action.support.master.TransportMasterNodeO perationAction.doExecute(TransportMasterNodeOperationAction.**
**java:42)
at org.elasticsearch.action.support.TransportAction.execute(Tra nsportAction.java:61)
at org.elasticsearch.action.support.master.TransportMasterNodeO perationAction.execute(TransportMasterNodeOperationAction.ja**
**va:89)
at org.elasticsearch.action.support.master.TransportMasterNodeO perationAction$TransportHandler.messageReceived(TransportMas terNodeOperationAction.java:26*6)
at org.elasticsearch.action.support.master.TransportMasterNodeO perationAction$TransportHandler.messageReceived(TransportMas terNodeOperationAction.java:25*0)
at org.elasticsearch.transport.netty.MessageChannelHandler.hand leRequest(MessageChannelHandler.java:211)
at org.elasticsearch.transport.netty.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.ThreadPoo*lExecutor$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.
--
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 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();
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.
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.
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(T
ransportClusterStateAction.java:101)
at org.elasticsearch.action.admin.cluster.state.
TransportClusterStateAction.masterOperation(T
ransportClusterStateAction.java:42)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$2.run(Transport
MasterNodeOperationAction.java******:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$
SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.innerExecute(Tr
ansportMasterNodeOperationAction.java:140)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(Trans
portMasterNodeOperationAction.java:94)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(Trans
portMasterNodeOperationAction.java:42)
at org.elasticsearch.action.support.TransportAction.execute(
TransportAction.java:61)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.execute(Transpo
rtMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceived(TransportMasterNodeOperationAction.java:26 6)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceived(TransportMasterNodeOperationAction.java:25 0)
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(SimpleC
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipeline.sendUpstream(DefaultChannelP
ipeline.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(SimpleC
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipeline.sendUpstream(DefaultChannelP
ipeline.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(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipeline.sendUpstream(DefaultChannelP
ipeline.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.
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();
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.
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.
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(T
ransportClusterStateAction.java:101)
at org.elasticsearch.action.admin.cluster.state.
TransportClusterStateAction.masterOperation(T
ransportClusterStateAction.java:42)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$2.run(Transport
MasterNodeOperationAction.java******:144)
at org.elasticsearch.common.util.concurrent.MoreExecutors$
SameThreadExecutorService.execute(MoreExecutors.java:293)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.innerExecute(Tr
ansportMasterNodeOperationAction.java:140)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(Trans
portMasterNodeOperationAction.java:94)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.doExecute(Trans
portMasterNodeOperationAction.java:42)
at org.elasticsearch.action.support.TransportAction.execute(
TransportAction.java:61)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction.execute(Transpo
rtMasterNodeOperationAction.java:89)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceived(TransportMasterNodeOperatio**nAction.java:26 6)
at org.elasticsearch.action.support.master.
TransportMasterNodeOperationAction$**TransportHandler.
messageReceived(TransportMasterNodeOperatio**nAction.java:25 0)
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(SimpleC
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipeline.sendUpstream(DefaultChannelP
ipeline.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(SimpleC
hannelUpstreamHandler.java:70)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipeline.sendUpstream(DefaultChannelP
ipeline.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(DefaultChannelP
ipeline.java:564)
at org.elasticsearch.common.netty******.channel.
DefaultChannelPipeline.sendUpstream(DefaultChannelP
ipeline.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.
--
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.
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.