I turned on the debugging and I'm seeing this on the search node. It looks
like the client makes a connection, but then disconnects.
This is the search node log when using TransportClient.
[2013-07-02 10:42:58,844][DEBUG][http.netty ] [Caiera] Caught
exception while handling client http traffic, closing connection [id:
0x286957a3, /1
27.0.0.1:2609 => /127.0.0.1:9200]
java.io.IOException: An existing connection was forcibly closed by the
remote host
at sun.nio.ch.SocketDispatcher.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:25)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198)
at sun.nio.ch.IOUtil.read(IOUtil.java:166)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)
at
org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64)
at
org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:107)
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:88)
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:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
[2013-07-02 10:42:58,844][DEBUG][http.netty ] [Caiera] Caught
exception while handling client http traffic, closing connection [id:
0xe3612f1f, /1
27.0.0.1:2608 => /127.0.0.1:9200]
java.io.IOException: An existing connection was forcibly closed by the
remote host
at sun.nio.ch.SocketDispatcher.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:25)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198)
at sun.nio.ch.IOUtil.read(IOUtil.java:166)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)
at
org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64)
at
org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:107)
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:88)
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:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
When I now change the client code to use nodeBuilder I see the following on
the search node:
[2013-07-02 10:46:26,148][DEBUG][transport.netty ] [Caiera]
connected to node
[[Aardwolf][GDm3DJCFSbiaohcW0G1vKA][inet[/x.x.x.x:9300]]{client=tru
, data=false}]
[2013-07-02 10:46:26,151][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [1]
[2013-07-02 10:46:27,670][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [1]
[2013-07-02 10:46:29,177][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [2]
[2013-07-02 10:46:30,683][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [2]
[2013-07-02 10:46:32,180][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [3]
[2013-07-02 10:46:33,679][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [3]
[2013-07-02 10:46:35,181][WARN ][discovery.zen.ping.multicast] [Caiera]
received ping response ping_response{target
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/10.
43.13.57:9300]]], master
[[Caiera][Fhm9sxcbS4myeJRVKsehzA][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [4]
On the client I see the following - which seems to indicate that it can't
find the master.
Jul 02, 2013 10:46:56 AM org.elasticsearch.discovery
WARNING: [Aardwolf] waited for 30s and no initial state was set by the
discovery
Jul 02, 2013 10:46:56 AM org.elasticsearch.discovery
INFO: [Aardwolf] elasticsearch/GDm3DJCFSbiaohcW0G1vKA
Jul 02, 2013 10:46:56 AM org.elasticsearch.http
INFO: [Aardwolf] bound_address {inet[/0:0:0:0:0:0:0:0:9200]},
publish_address {inet[/x.x.x.x:9200]}
Jul 02, 2013 10:46:56 AM org.elasticsearch.node
INFO: [Aardwolf] {0.90.1}[9556]: started
Loading....
Exception in thread "main"
org.elasticsearch.discovery.MasterNotDiscoveredException: waited for [30s]
at
org.elasticsearch.action.support.master.TransportMasterNodeOperationAction$3.onTimeout(TransportMasterNodeOperationAction.java:169)
at
org.elasticsearch.cluster.service.InternalClusterService$NotifyTimeout.run(InternalClusterService.java:377)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
On Monday, July 1, 2013 11:58:10 AM UTC-6, Henri van den Bulk wrote:
I'm building a simple Java Client same as mentioned posted under Java
client can't start a node.https://groups.google.com/forum/#!searchin/elasticsearch/$20cluster_name[elasticsearch]}$20with$20no$20matching$20id/elasticsearch/dI9J3lzaMJY/8vYjN-qYKYIJ But
I did not see a resolution there.
Both the Elasticsearch node instance and the client are running on my
local machine. Firewall is not blocking connections as all firewalls are
shutdown and I have tested the ports.
NodeBuilder builder = nodeBuilder();
builder.client(true);
// Build and start the node.
node = builder.node();
client = node.client();
On the node I keep getting the following logs:
master [[Kick-Ass][r6GYgCbfT46UuuFBguCuAQ][inet[/x.x.x.x:9300]]],
cluster_name[elasticsearch]} with no matching id [21]
The client gets:
Exception in thread "main"
org.elasticsearch.discovery.MasterNotDiscoveredException: waited for [30s]
at
org.elasticsearch.action.support.master.TransportMasterNodeOperationAction$3.onTimeout(TransportMasterNodeOperationAction.java:169)
at
org.elasticsearch.cluster.service.InternalClusterService$NotifyTimeout.run(InternalClusterService.java:377)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
--
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.