Unable to connect to Infinispan cluster using HotRod
anandnalya Feb 26, 2014 2:55 AMHi,
I'm trying to run Infinspan in a two node cluster. I'm using the infinispan-server-6.0.0.Final-bin.zip distribution on CentOS 6.4, 64 bit. I'm using JDK 1.6.41.
On the two nodes, I'm using the following commands to start the server:
On server with ip (192.168.41.168)# ./bin/clustered.sh -b=192.168.41.168 -c=clustered-two-nodes.xml -Djboss.node.name=nodeC
On server with ip (192.168.41.105)# ./bin/clustered.sh -b=192.168.41.105 -c=clustered-two-nodes.xml -Djboss.node.name=nodeD
The cluster is forming properly as I'm getting the following message on one of the nodes:
14:05:56,160 INFO [org.infinispan.remoting.transport.jgroups.JGroupsTransport] (Incoming-1,shared=udp) ISPN000094: Received new cluster view: [nodeC/clustered|1] (2) [nodeC/clustered, nodeD/clustered]
Now, when trying to connect with the cluster using HotRod, I'm getting the following logs:
2014-02-24 14:12:39,545 DEBUG [jboss.logging] (main) Logging Provider: org.jboss.logging.Log4jLoggerProvider
2014-02-24 14:12:39,590 DEBUG [tcp.TcpTransportFactory] (main) Statically configured servers: [/192.168.41.168:11222, /192.168.41.105:11222]
2014-02-24 14:12:39,590 DEBUG [tcp.TcpTransportFactory] (main) Load balancer class: org.infinispan.client.hotrod.impl.transport.tcp.RoundRobinBalancingStrategy
2014-02-24 14:12:39,591 DEBUG [tcp.TcpTransportFactory] (main) Tcp no delay = true; client socket timeout = 60000 ms; connect timeout = 60000 ms
2014-02-24 14:12:39,689 INFO [hotrod.RemoteCacheManager] (main) ISPN004021: Infinispan version: 6.0.1.Final
2014-02-24 14:12:39,948 INFO [protocol.Codec12] (main) ISPN004006: /192.168.41.105:11222 sent new topology view (id=0) containing 1 addresses: [/192.168.41.105:11222]
2014-02-24 14:12:39,948 INFO [tcp.TcpTransportFactory] (main) ISPN004016: Server not in cluster anymore(/192.168.41.168:11222), removing from the pool.
The code for connecting to the cluster is as follows:
ConfigurationBuilder builder = new ConfigurationBuilder();
builder.addServer().host("192.168.41.168").port(11222);
builder.addServer().host("192.168.41.105").port(11222);
RemoteCacheManager cacheContainer = new RemoteCacheManager(builder.build());
RemoteCache<String, Object> cache = cacheContainer.getCache("default123");
Everything works find if I run both the nodes on a single machine. Any idea what might be wrong here?
I'm also attaching the configuration file I'm using.
Added server logs.
-
clustered-two-nodes.xml 12.5 KB
-
server-2.log.zip 3.5 KB
-
server-1.log.zip 3.8 KB