Ignite Node Connection Issue

classic Classic list List threaded Threaded
4 messages Options
sri hari kali charan Tummala sri hari kali charan Tummala
Reply | Threaded
Open this post in threaded view
|

Ignite Node Connection Issue

Hi All, 

I was able to create a working ignite cluster (https://www.gridgain.com/docs/8.7.6//installation-guide/manual-install-on-ec2) on AWS I opened all the ports in my security group but when I try to connect ignite cluster from my Local PC Scala Code ignite fails with below error.

I am using example-default.xml file 
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://apacheignite.readme.io/docs/cluster-config
-->
<!-- Uncomment static IP finder to enable static-based discovery of initial nodes. -->
<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<!-- <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> -->
<property name="addresses">
<list>
<!-- In distributed environment, replace with actual host IP address. -->
<value>3.86.250.240:47100..47200</value>
<value>3.84.154.193:47100..47200</value>
<value>127.0.0.1:47100..47200</value>
</list>
</property>
</bean>
</property>
</bean>
</property>

Failed to connect to any address from IP finder (make sure IP finder addresses are correct and firewalls are disabled on all host machines)

Error on Ignite Ec2 instance:-

class org.apache.ignite.internal.util.nio.GridNioException: Invalid message type: -4692

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2437)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.bodyInternal(GridNioServer.java:2178)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1819)

at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:119)

at java.lang.Thread.run(Thread.java:748)

Caused by: class org.apache.ignite.IgniteException: Invalid message type: -4692

at org.apache.ignite.internal.managers.communication.GridIoMessageFactory.create(GridIoMessageFactory.java:1151)

at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$6.create(TcpCommunicationSpi.java:2336)

at org.apache.ignite.internal.util.nio.GridDirectParser.decode(GridDirectParser.java:80)

at org.apache.ignite.internal.util.nio.GridNioCodecFilter.onMessageReceived(GridNioCodecFilter.java:113)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridConnectionBytesVerifyFilter.onMessageReceived(GridConnectionBytesVerifyFilter.java:132)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridNioServer$HeadFilter.onMessageReceived(GridNioServer.java:3575)

at org.apache.ignite.internal.util.nio.GridNioFilterChain.onMessageReceived(GridNioFilterChain.java:174)

at org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processRead(GridNioServer.java:1312)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2411



--
Thanks & Regards
Sri Tummala


Screen Shot 2019-10-16 at 3.38.35 PM.png (147K) Download Attachment
sri hari kali charan Tummala sri hari kali charan Tummala
Reply | Threaded
Open this post in threaded view
|

Re: Ignite Node Connection Issue

I even tried with simple scala code still no luck!

Error:-
Failed to connect to any address from IP finder (will retry to join topology every 2000 ms; change 'reconnectDelay' to configure the frequency of retries):

package com.ignite.examples.igniteStartup

import org.apache.ignite.Ignite
import org.apache.ignite.IgniteCache
import org.apache.ignite.Ignition
import org.apache.ignite.configuration.IgniteConfiguration
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder
import org.apache.ignite.configuration.IgniteConfiguration
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder
import java.util.Arrays
import java.util.List
import scala.collection.JavaConversions._

object IgniteClientConnection {
def main(args: Array[String]): Unit = {

val spi = new TcpDiscoverySpi
val ipFinder = new TcpDiscoveryVmIpFinder
val hostList: List[String] = Arrays.asList(("ec2-100-25-173-220:47500..47509," +
"ec2-100-25-173-220.compute-1.amazonaws.com:47500..47509," +
"3.86.250.240:47500..47509," +
"172.31.81.211:47500..47509," +
"100.25.173.220:47500..47509").split(","): _*)

ipFinder.setAddresses(hostList)
spi.setIpFinder(ipFinder)
val cfg = new IgniteConfiguration
cfg.setDiscoverySpi(spi)
cfg.setClientMode(true)
cfg.setPeerClassLoadingEnabled(true)

val ignite: Ignite = Ignition.start(cfg)
Ignition.ignite().cache("test")
//LOG.info(">>> cache acquired")


}

}

On Wed, Oct 16, 2019 at 3:41 PM sri hari kali charan Tummala <[hidden email]> wrote:
Hi All, 

I was able to create a working ignite cluster (https://www.gridgain.com/docs/8.7.6//installation-guide/manual-install-on-ec2) on AWS I opened all the ports in my security group but when I try to connect ignite cluster from my Local PC Scala Code ignite fails with below error.

I am using example-default.xml file 
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://apacheignite.readme.io/docs/cluster-config
-->
<!-- Uncomment static IP finder to enable static-based discovery of initial nodes. -->
<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<!-- <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> -->
<property name="addresses">
<list>
<!-- In distributed environment, replace with actual host IP address. -->
<value>3.86.250.240:47100..47200</value>
<value>3.84.154.193:47100..47200</value>
<value>127.0.0.1:47100..47200</value>
</list>
</property>
</bean>
</property>
</bean>
</property>

Failed to connect to any address from IP finder (make sure IP finder addresses are correct and firewalls are disabled on all host machines)

Error on Ignite Ec2 instance:-

class org.apache.ignite.internal.util.nio.GridNioException: Invalid message type: -4692

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2437)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.bodyInternal(GridNioServer.java:2178)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1819)

at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:119)

at java.lang.Thread.run(Thread.java:748)

Caused by: class org.apache.ignite.IgniteException: Invalid message type: -4692

at org.apache.ignite.internal.managers.communication.GridIoMessageFactory.create(GridIoMessageFactory.java:1151)

at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$6.create(TcpCommunicationSpi.java:2336)

at org.apache.ignite.internal.util.nio.GridDirectParser.decode(GridDirectParser.java:80)

at org.apache.ignite.internal.util.nio.GridNioCodecFilter.onMessageReceived(GridNioCodecFilter.java:113)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridConnectionBytesVerifyFilter.onMessageReceived(GridConnectionBytesVerifyFilter.java:132)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridNioServer$HeadFilter.onMessageReceived(GridNioServer.java:3575)

at org.apache.ignite.internal.util.nio.GridNioFilterChain.onMessageReceived(GridNioFilterChain.java:174)

at org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processRead(GridNioServer.java:1312)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2411



--
Thanks & Regards
Sri Tummala



--
Thanks & Regards
Sri Tummala

Denis Mekhanikov Denis Mekhanikov
Reply | Threaded
Open this post in threaded view
|

Re: Ignite Node Connection Issue

I answered to you on stackoverflow: https://stackoverflow.com/questions/58422096/failing-to-connect-apache-ignite-cluster
You need to use the port 10800 for thin clients instead of 47xxx

Denis
On 17 Oct 2019, 00:08 +0300, sri hari kali charan Tummala <[hidden email]>, wrote:
I even tried with simple scala code still no luck!

Error:-
Failed to connect to any address from IP finder (will retry to join topology every 2000 ms; change 'reconnectDelay' to configure the frequency of retries):

package com.ignite.examples.igniteStartup

import org.apache.ignite.Ignite
import org.apache.ignite.IgniteCache
import org.apache.ignite.Ignition
import org.apache.ignite.configuration.IgniteConfiguration
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder
import org.apache.ignite.configuration.IgniteConfiguration
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder
import java.util.Arrays
import java.util.List
import scala.collection.JavaConversions._

object IgniteClientConnection {
def main(args: Array[String]): Unit = {

val spi = new TcpDiscoverySpi
val ipFinder = new TcpDiscoveryVmIpFinder
val hostList: List[String] = Arrays.asList(("ec2-100-25-173-220:47500..47509," +
"ec2-100-25-173-220.compute-1.amazonaws.com:47500..47509," +
"3.86.250.240:47500..47509," +
"172.31.81.211:47500..47509," +
"100.25.173.220:47500..47509").split(","): _*)

ipFinder.setAddresses(hostList)
spi.setIpFinder(ipFinder)
val cfg = new IgniteConfiguration
cfg.setDiscoverySpi(spi)
cfg.setClientMode(true)
cfg.setPeerClassLoadingEnabled(true)

val ignite: Ignite = Ignition.start(cfg)
Ignition.ignite().cache("test")
//LOG.info(">>> cache acquired")


}

}

On Wed, Oct 16, 2019 at 3:41 PM sri hari kali charan Tummala <[hidden email]> wrote:
Hi All, 

I was able to create a working ignite cluster (https://www.gridgain.com/docs/8.7.6//installation-guide/manual-install-on-ec2) on AWS I opened all the ports in my security group but when I try to connect ignite cluster from my Local PC Scala Code ignite fails with below error.

I am using example-default.xml file 
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://apacheignite.readme.io/docs/cluster-config
-->
<!-- Uncomment static IP finder to enable static-based discovery of initial nodes. -->
<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<!-- <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> -->
<property name="addresses">
<list>
<!-- In distributed environment, replace with actual host IP address. -->
<value>3.86.250.240:47100..47200</value>
<value>3.84.154.193:47100..47200</value>
<value>127.0.0.1:47100..47200</value>
</list>
</property>
</bean>
</property>
</bean>
</property>

Failed to connect to any address from IP finder (make sure IP finder addresses are correct and firewalls are disabled on all host machines)

Error on Ignite Ec2 instance:-

class org.apache.ignite.internal.util.nio.GridNioException: Invalid message type: -4692

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2437)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.bodyInternal(GridNioServer.java:2178)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1819)

at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:119)

at java.lang.Thread.run(Thread.java:748)

Caused by: class org.apache.ignite.IgniteException: Invalid message type: -4692

at org.apache.ignite.internal.managers.communication.GridIoMessageFactory.create(GridIoMessageFactory.java:1151)

at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$6.create(TcpCommunicationSpi.java:2336)

at org.apache.ignite.internal.util.nio.GridDirectParser.decode(GridDirectParser.java:80)

at org.apache.ignite.internal.util.nio.GridNioCodecFilter.onMessageReceived(GridNioCodecFilter.java:113)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridConnectionBytesVerifyFilter.onMessageReceived(GridConnectionBytesVerifyFilter.java:132)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridNioServer$HeadFilter.onMessageReceived(GridNioServer.java:3575)

at org.apache.ignite.internal.util.nio.GridNioFilterChain.onMessageReceived(GridNioFilterChain.java:174)

at org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processRead(GridNioServer.java:1312)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2411



--
Thanks & Regards
Sri Tummala



--
Thanks & Regards
Sri Tummala

sri hari kali charan Tummala sri hari kali charan Tummala
Reply | Threaded
Open this post in threaded view
|

Re: Ignite Node Connection Issue

Thank you, worked like a charm!

On Thu, Oct 17, 2019 at 5:14 AM Denis Mekhanikov <[hidden email]> wrote:
I answered to you on stackoverflow: https://stackoverflow.com/questions/58422096/failing-to-connect-apache-ignite-cluster
You need to use the port 10800 for thin clients instead of 47xxx

Denis
On 17 Oct 2019, 00:08 +0300, sri hari kali charan Tummala <[hidden email]>, wrote:
I even tried with simple scala code still no luck!

Error:-
Failed to connect to any address from IP finder (will retry to join topology every 2000 ms; change 'reconnectDelay' to configure the frequency of retries):

package com.ignite.examples.igniteStartup

import org.apache.ignite.Ignite
import org.apache.ignite.IgniteCache
import org.apache.ignite.Ignition
import org.apache.ignite.configuration.IgniteConfiguration
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder
import org.apache.ignite.configuration.IgniteConfiguration
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder
import java.util.Arrays
import java.util.List
import scala.collection.JavaConversions._

object IgniteClientConnection {
def main(args: Array[String]): Unit = {

val spi = new TcpDiscoverySpi
val ipFinder = new TcpDiscoveryVmIpFinder
val hostList: List[String] = Arrays.asList(("ec2-100-25-173-220:47500..47509," +
"ec2-100-25-173-220.compute-1.amazonaws.com:47500..47509," +
"3.86.250.240:47500..47509," +
"172.31.81.211:47500..47509," +
"100.25.173.220:47500..47509").split(","): _*)

ipFinder.setAddresses(hostList)
spi.setIpFinder(ipFinder)
val cfg = new IgniteConfiguration
cfg.setDiscoverySpi(spi)
cfg.setClientMode(true)
cfg.setPeerClassLoadingEnabled(true)

val ignite: Ignite = Ignition.start(cfg)
Ignition.ignite().cache("test")
//LOG.info(">>> cache acquired")


}

}

On Wed, Oct 16, 2019 at 3:41 PM sri hari kali charan Tummala <[hidden email]> wrote:
Hi All, 

I was able to create a working ignite cluster (https://www.gridgain.com/docs/8.7.6//installation-guide/manual-install-on-ec2) on AWS I opened all the ports in my security group but when I try to connect ignite cluster from my Local PC Scala Code ignite fails with below error.

I am using example-default.xml file 
<property name="discoverySpi">
<bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<!--
Ignite provides several options for automatic discovery that can be used
instead os static IP based discovery. For information on all options refer
to our documentation: http://apacheignite.readme.io/docs/cluster-config
-->
<!-- Uncomment static IP finder to enable static-based discovery of initial nodes. -->
<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<!-- <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> -->
<property name="addresses">
<list>
<!-- In distributed environment, replace with actual host IP address. -->
<value>3.86.250.240:47100..47200</value>
<value>3.84.154.193:47100..47200</value>
<value>127.0.0.1:47100..47200</value>
</list>
</property>
</bean>
</property>
</bean>
</property>

Failed to connect to any address from IP finder (make sure IP finder addresses are correct and firewalls are disabled on all host machines)

Error on Ignite Ec2 instance:-

class org.apache.ignite.internal.util.nio.GridNioException: Invalid message type: -4692

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2437)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.bodyInternal(GridNioServer.java:2178)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.body(GridNioServer.java:1819)

at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:119)

at java.lang.Thread.run(Thread.java:748)

Caused by: class org.apache.ignite.IgniteException: Invalid message type: -4692

at org.apache.ignite.internal.managers.communication.GridIoMessageFactory.create(GridIoMessageFactory.java:1151)

at org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$6.create(TcpCommunicationSpi.java:2336)

at org.apache.ignite.internal.util.nio.GridDirectParser.decode(GridDirectParser.java:80)

at org.apache.ignite.internal.util.nio.GridNioCodecFilter.onMessageReceived(GridNioCodecFilter.java:113)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridConnectionBytesVerifyFilter.onMessageReceived(GridConnectionBytesVerifyFilter.java:132)

at org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:108)

at org.apache.ignite.internal.util.nio.GridNioServer$HeadFilter.onMessageReceived(GridNioServer.java:3575)

at org.apache.ignite.internal.util.nio.GridNioFilterChain.onMessageReceived(GridNioFilterChain.java:174)

at org.apache.ignite.internal.util.nio.GridNioServer$DirectNioClientWorker.processRead(GridNioServer.java:1312)

at org.apache.ignite.internal.util.nio.GridNioServer$AbstractNioClientWorker.processSelectedKeysOptimized(GridNioServer.java:2411



--
Thanks & Regards
Sri Tummala



--
Thanks & Regards
Sri Tummala



--
Thanks & Regards
Sri Tummala