Re: Connection Refused in Scala Ignite Client (Help!)

2019-10-17 Thread sri hari kali charan Tummala 
worked like a charm, thank you.

On Thu, Oct 17, 2019 at 2:54 AM Artem Budnikov 
wrote:

> Hi,
>
> Looks like you are trying to connect to the wrong port. The default port
> for client connection is 10800.
>
> Change:
>
> val cfg2 = new ClientConfiguration().setAddresses("100.25.173.220:47100
> ..47700")
>
> to
>
> val cfg2 = new ClientConfiguration().setAddresses("100.25.173.220:10800")
>
>
> -Artem
> On 17.10.2019 03:39, alexanderko...@gmail.com wrote:
>
> You need to replace the ip finder on all nodes to use the s3 one.
>
> add the libraries from libs/optional/ignite-aws to your application's
> classpath.
>
> No file is required.
>
>
>
> *From:* sri hari kali charan Tummala 
> 
> *Sent:* Wednesday, October 16, 2019 8:10 PM
> *To:* user@ignite.apache.org; alexanderko...@gmail.com
> *Subject:* Re: Connection Refused in Scala Ignite Client (Help!)
>
>
>
> I this below property is while launching ignite on aws
>
> I already have ignite cluster running I just need to connect using java or
> Scala code which is failing with  connection refused error.
>
>
>
> https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery
>
>
>
>
>
>
>
> On Wednesday, October 16, 2019, sri hari kali charan Tummala <
> kali.tumm...@gmail.com> wrote:
>
> Do I need to keep any file inside the s3 bucket or is it just a empty
> bucket ? With aws credentials and bucket name ?
>
>
>
>
>
> On Wednesday, October 16, 2019,  wrote:
>
> Hi,
>
>Try using the S3 IP Finder:
> https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery
>
>
>
>   
>
> 
>
>   
>
>  "org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder">
>
>   
>
>   
>
> 
>
>   
>
> 
>
>   
>
>
>
> Thanks, Alex
>
>
>
>
>
> *From:* sri hari kali charan Tummala 
> *Sent:* Wednesday, October 16, 2019 5:55 PM
> *To:* user@ignite.apache.org
> *Subject:* Connection Refused in Scala Ignite Client (Help!)
>
>
>
> Hi All,
>
>
>
> I am trying to connect my ignite cluster which is created on AWS (), now I
> am suing scala code to connect to the client which is failing with
> connection refused error.
>
>
>
> In my security group I opened all the ports still I am having issues can
> anyone help.
>
>
>
> Error:-
>
>
> *Exception in thread "main"
> org.apache.ignite.client.ClientConnectionException: Ignite cluster is
> unavailable at org.apache.i*
> gnite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:114)
> at
> org.apache.ignite.internal.client.thin.TcpIgniteClient.lambda$new$0(TcpIgniteClient.java:79)
> at
> org.apache.ignite.internal.client.thin.ReliableChannel.(ReliableChannel.java:84)
> at
> org.apache.ignite.internal.client.thin.TcpIgniteClient.(TcpIgniteClient.java:86)
> at
> org.apache.ignite.internal.client.thin.TcpIgniteClient.start(TcpIgniteClient.java:205)
> at org.apache.ignite.Ignition.startClient(Ignition.java:586)
> at
> com.ignite.examples.igniteStartup.IgniteClientConnection$.main(IgniteClientConnection.scala:36)
> at
> com.ignite.examples.igniteStartup.IgniteClientConnection.main(IgniteClientConnection.scala)
> *Caused by: java.net.ConnectException: Connection refused (Connection
> refused)*
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at java.net
> .AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
> at java.net
> .AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
> at java.net
> .AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at java.net.Socket.connect(Socket.java:538)
> at java.net.Socket.(Socket.java:434)
> at java.net.Socket.(Socket.java:211)
> at
> org.apache.ignite.internal.client.thin.TcpClientChannel.createSocket(TcpClientChannel.java:216)
> at
> org.apache.ignite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:108)
> ... 7 more
>
>
>
> Scala Code:-
>
> package com.ignite.examples.igniteStartup
> import org.apache.ignite.Igniteimport org.apache.ignite.IgniteCacheimport 
> org.apache.ignite.Ignitionimport 
> org.apache.ignite.configuration.{ClientConfiguration, 
> IgniteConfiguration}import 
> org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinderimport 
> org.apache.ignite.configuration.IgniteConfigurationimport 
> org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi

Re: Connection Refused in Scala Ignite Client (Help!)

2019-10-17 Thread Artem Budnikov 

Hi,

Looks like you are trying to connect to the wrong port. The default port 
for client connection is 10800.


Change:

val cfg2 = new 
ClientConfiguration().setAddresses("100.25.173.220:47100..47700")


to

val cfg2 = new ClientConfiguration().setAddresses("100.25.173.220:10800")


-Artem

On 17.10.2019 03:39, alexanderko...@gmail.com wrote:


You need to replace the ip finder on all nodes to use the s3 one.

add the libraries from |libs/optional/ignite-aws| to your 
application's classpath.


No file is required.

*From:* sri hari kali charan Tummala 
*Sent:* Wednesday, October 16, 2019 8:10 PM
*To:* user@ignite.apache.org; alexanderko...@gmail.com
*Subject:* Re: Connection Refused in Scala Ignite Client (Help!)

I this below property is while launching ignite on aws

I already have ignite cluster running I just need to connect using 
java or Scala code which is failing with  connection refused error.



https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery

On Wednesday, October 16, 2019, sri hari kali charan Tummala 
mailto:kali.tumm...@gmail.com>> wrote:


Do I need to keep any file inside the s3 bucket or is it just a
empty bucket ? With aws credentials and bucket name ?



On Wednesday, October 16, 2019, mailto:alexanderko...@gmail.com>> wrote:

Hi,

Try using the S3 IP Finder:

https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery






















Thanks, Alex

*From:* sri hari kali charan Tummala mailto:kali.tumm...@gmail.com>>
*Sent:* Wednesday, October 16, 2019 5:55 PM
*To:* user@ignite.apache.org <mailto:user@ignite.apache.org>
*Subject:* Connection Refused in Scala Ignite Client (Help!)

Hi All,

I am trying to connect my ignite cluster which is created on
AWS (), now I am suing scala code to connect to the
client which is failing with connection refused error.

In my security group I opened all the ports still I am having
issues can anyone help.

Error:-

*Exception in thread "main"
org.apache.ignite.client.ClientConnectionException: Ignite
cluster is unavailable
at

org.apache.i*gnite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:114)
at

org.apache.ignite.internal.client.thin.TcpIgniteClient.lambda$new$0(TcpIgniteClient.java:79)
at

org.apache.ignite.internal.client.thin.ReliableChannel.(ReliableChannel.java:84)
at

org.apache.ignite.internal.client.thin.TcpIgniteClient.(TcpIgniteClient.java:86)
at

org.apache.ignite.internal.client.thin.TcpIgniteClient.start(TcpIgniteClient.java:205)
at org.apache.ignite.Ignition.startClient(Ignition.java:586)
at

com.ignite.examples.igniteStartup.IgniteClientConnection$.main(IgniteClientConnection.scala:36)
at

com.ignite.examples.igniteStartup.IgniteClientConnection.main(IgniteClientConnection.scala)
*Caused by: java.net.ConnectException: Connection refused
(Connection refused)*
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net

<http://java.net>.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net

<http://java.net>.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net

<http://java.net>.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at java.net.Socket.connect(Socket.java:538)
at java.net.Socket.(Socket.java:434)
at java.net.Socket.(Socket.java:211)
at

org.apache.ignite.internal.client.thin.TcpClientChannel.createSocket(TcpClientChannel.java:216)
at

org.apache.ignite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:108)
... 7 more

Scala Code:-

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.{ClientConfiguration,
IgniteConfiguration} 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
com.ignite.examples.model.Address import
org.apache.ignite.client.{ClientCache

RE: Connection Refused in Scala Ignite Client (Help!)

2019-10-16 Thread alexanderkor12 
You need to replace the ip finder on all nodes to use the s3 one. 

add the libraries from libs/optional/ignite-aws to your application's classpath.

No file is required.

 

From: sri hari kali charan Tummala  
Sent: Wednesday, October 16, 2019 8:10 PM
To: user@ignite.apache.org; alexanderko...@gmail.com
Subject: Re: Connection Refused in Scala Ignite Client (Help!)

 

I this below property is while launching ignite on aws 

I already have ignite cluster running I just need to connect using java or 
Scala code which is failing with  connection refused error.


https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery

 

 

 

On Wednesday, October 16, 2019, sri hari kali charan Tummala 
mailto:kali.tumm...@gmail.com> > wrote:

Do I need to keep any file inside the s3 bucket or is it just a empty bucket ? 
With aws credentials and bucket name ?

 



On Wednesday, October 16, 2019, mailto:alexanderko...@gmail.com> > wrote:

Hi,

   Try using the S3 IP Finder: 
https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery

 

  



  



  

  



  



  

 

Thanks, Alex

 

 

From: sri hari kali charan Tummala mailto:kali.tumm...@gmail.com> > 
Sent: Wednesday, October 16, 2019 5:55 PM
To: user@ignite.apache.org <mailto:user@ignite.apache.org> 
Subject: Connection Refused in Scala Ignite Client (Help!)

 

Hi All, 

 

I am trying to connect my ignite cluster which is created on AWS (), now I am 
suing scala code to connect to the client which is failing with connection 
refused error.

 

In my security group I opened all the ports still I am having issues can anyone 
help.

 

Error:-

Exception in thread "main" org.apache.ignite.client.ClientConnectionException: 
Ignite cluster is unavailable
at 
org.apache.ignite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:114)
at 
org.apache.ignite.internal.client.thin.TcpIgniteClient.lambda$new$0(TcpIgniteClient.java:79)
at 
org.apache.ignite.internal.client.thin.ReliableChannel.(ReliableChannel.java:84)
at 
org.apache.ignite.internal.client.thin.TcpIgniteClient.(TcpIgniteClient.java:86)
at 
org.apache.ignite.internal.client.thin.TcpIgniteClient.start(TcpIgniteClient.java:205)
at org.apache.ignite.Ignition.startClient(Ignition.java:586)
at 
com.ignite.examples.igniteStartup.IgniteClientConnection$.main(IgniteClientConnection.scala:36)
at 
com.ignite.examples.igniteStartup.IgniteClientConnection.main(IgniteClientConnection.scala)
Caused by: java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net <http://java.net> 
.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net <http://java.net> 
.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net <http://java.net> 
.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at java.net.Socket.connect(Socket.java:538)
at java.net.Socket.(Socket.java:434)
at java.net.Socket.(Socket.java:211)
at 
org.apache.ignite.internal.client.thin.TcpClientChannel.createSocket(TcpClientChannel.java:216)
at 
org.apache.ignite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:108)
... 7 more

 

Scala Code:-

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.{ClientConfiguration, 
IgniteConfiguration}
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 com.ignite.examples.model.Address
import org.apache.ignite.client.{ClientCache, IgniteClient}

import scala.collection.JavaConversions._

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

System.out.println()
System.out.println(">>> Thin client put-get example started.")
System.out.println(">>> I am here.")

val cfg2 = new ClientConfiguration().setAddresses("100.25.173.220 
<http://100.25.173.220> :47100..47700")
val igniteClient:IgniteClient = Ignition.startClient(cfg2)
val CACHE_NAME = "put-get-example";
//val cache:ClientCache[Integer, Address] = 
igniteClient.getOrCreateCache(CACHE_NAME)

System.out.format(">>> Created cache [%s].\n", CACHE_NAME)



  }

}

 

-- 

Thanks & Regards

Sri Tummala

 



-- 
Thanks & Regards

Sri Tummala

 

 



-- 
Thanks & Regards

Sri Tummala

Re: Connection Refused in Scala Ignite Client (Help!)

2019-10-16 Thread sri hari kali charan Tummala 
I this below property is while launching ignite on aws
I already have ignite cluster running I just need to connect using java or
Scala code which is failing with  connection refused error.

https://apacheignite-mix.readme.io/docs/amazon-aws#section-
amazon-s3-based-discovery



On Wednesday, October 16, 2019, sri hari kali charan Tummala <
kali.tumm...@gmail.com> wrote:

> Do I need to keep any file inside the s3 bucket or is it just a empty
> bucket ? With aws credentials and bucket name ?
>
>
>
> On Wednesday, October 16, 2019,  wrote:
>
>> Hi,
>>
>>Try using the S3 IP Finder: https://apacheignite-mix.readm
>> e.io/docs/amazon-aws#section-amazon-s3-based-discovery
>>
>>
>>
>>   
>>
>> 
>>
>>   
>>
>> 
>>
>>   
>>
>>   
>>
>> 
>>
>>   
>>
>> 
>>
>>   
>>
>>
>>
>> Thanks, Alex
>>
>>
>>
>>
>>
>> *From:* sri hari kali charan Tummala 
>> *Sent:* Wednesday, October 16, 2019 5:55 PM
>> *To:* user@ignite.apache.org
>> *Subject:* Connection Refused in Scala Ignite Client (Help!)
>>
>>
>>
>> Hi All,
>>
>>
>>
>> I am trying to connect my ignite cluster which is created on AWS (), now
>> I am suing scala code to connect to the client which is failing with
>> connection refused error.
>>
>>
>>
>> In my security group I opened all the ports still I am having issues can
>> anyone help.
>>
>>
>>
>> Error:-
>>
>>
>> *Exception in thread "main"
>> org.apache.ignite.client.ClientConnectionException: Ignite cluster is
>> unavailableat org.apache.i*gnite.internal.cli
>> ent.thin.TcpClientChannel.(TcpClientChannel.java:114)
>> at org.apache.ignite.internal.client.thin.TcpIgniteClient.lambd
>> a$new$0(TcpIgniteClient.java:79)
>> at org.apache.ignite.internal.client.thin.ReliableChannel.> >(ReliableChannel.java:84)
>> at org.apache.ignite.internal.client.thin.TcpIgniteClient.> >(TcpIgniteClient.java:86)
>> at org.apache.ignite.internal.client.thin.TcpIgniteClient.start
>> (TcpIgniteClient.java:205)
>> at org.apache.ignite.Ignition.startClient(Ignition.java:586)
>> at com.ignite.examples.igniteStartup.IgniteClientConnection$.
>> main(IgniteClientConnection.scala:36)
>> at com.ignite.examples.igniteStartup.IgniteClientConnection.
>> main(IgniteClientConnection.scala)
>> *Caused by: java.net.ConnectException: Connection refused (Connection
>> refused)*
>> at java.net.PlainSocketImpl.socketConnect(Native Method)
>> at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSock
>> etImpl.java:350)
>> at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPl
>> ainSocketImpl.java:206)
>> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocket
>> Impl.java:188)
>> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
>> at java.net.Socket.connect(Socket.java:589)
>> at java.net.Socket.connect(Socket.java:538)
>> at java.net.Socket.(Socket.java:434)
>> at java.net.Socket.(Socket.java:211)
>> at org.apache.ignite.internal.client.thin.TcpClientChannel.crea
>> teSocket(TcpClientChannel.java:216)
>> at org.apache.ignite.internal.client.thin.TcpClientChannel.> t>(TcpClientChannel.java:108)
>> ... 7 more
>>
>>
>>
>> Scala Code:-
>>
>> 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.{ClientConfiguration, 
>> IgniteConfiguration}
>> 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 com.ignite.examples.model.Address
>> import org.apache.ignite.client.{ClientCache, IgniteClient}
>>
>> import scala.collection.JavaConversions._
>>
>> object IgniteClientConnection {
>>   def main(args: Array[String]): Unit = {
>>
>> System.*out*.println()
>> System.*out*.println(">>> Thin client put-get example started.")
>> System.*out*.println(">>> I am here.")
>>
>> val cfg2 = new 
>> ClientConfiguration().setAddresses("100.25.173.220:47100..47700")
>> val igniteClient:IgniteClient = Ignition.*startClient*(cfg2)
>> val CACHE_NAME = "put-get-example";
>> //val cache:ClientCache[Integer, Address] = 
>> igniteClient.getOrCreateCache(CACHE_NAME)
>>
>> System.*out*.format(">>> Created cache [%s].\n", CACHE_NAME)
>>
>>
>>
>>   }
>>
>> }
>>
>>
>>
>> --
>>
>> Thanks & Regards
>>
>> Sri Tummala
>>
>>
>>
>
>
> --
> Thanks & Regards
> Sri Tummala
>
>
>

-- 
Thanks & Regards
Sri Tummala

Re: Connection Refused in Scala Ignite Client (Help!)

2019-10-16 Thread sri hari kali charan Tummala 
Do I need to keep any file inside the s3 bucket or is it just a empty
bucket ? With aws credentials and bucket name ?



On Wednesday, October 16, 2019,  wrote:

> Hi,
>
>Try using the S3 IP Finder: https://apacheignite-mix.
> readme.io/docs/amazon-aws#section-amazon-s3-based-discovery
>
>
>
>   
>
> 
>
>   
>
> 
>
>   
>
>   
>
> 
>
>   
>
> 
>
>   
>
>
>
> Thanks, Alex
>
>
>
>
>
> *From:* sri hari kali charan Tummala 
> *Sent:* Wednesday, October 16, 2019 5:55 PM
> *To:* user@ignite.apache.org
> *Subject:* Connection Refused in Scala Ignite Client (Help!)
>
>
>
> Hi All,
>
>
>
> I am trying to connect my ignite cluster which is created on AWS (), now I
> am suing scala code to connect to the client which is failing with
> connection refused error.
>
>
>
> In my security group I opened all the ports still I am having issues can
> anyone help.
>
>
>
> Error:-
>
>
> *Exception in thread "main"
> org.apache.ignite.client.ClientConnectionException: Ignite cluster is
> unavailableat org.apache.i*gnite.internal.client.thin.TcpClientChannel.<
> init>(TcpClientChannel.java:114)
> at org.apache.ignite.internal.client.thin.TcpIgniteClient.
> lambda$new$0(TcpIgniteClient.java:79)
> at org.apache.ignite.internal.client.thin.ReliableChannel.<
> init>(ReliableChannel.java:84)
> at org.apache.ignite.internal.client.thin.TcpIgniteClient.<
> init>(TcpIgniteClient.java:86)
> at org.apache.ignite.internal.client.thin.TcpIgniteClient.
> start(TcpIgniteClient.java:205)
> at org.apache.ignite.Ignition.startClient(Ignition.java:586)
> at com.ignite.examples.igniteStartup.IgniteClientConnection$.main(
> IgniteClientConnection.scala:36)
> at com.ignite.examples.igniteStartup.IgniteClientConnection.main(
> IgniteClientConnection.scala)
> *Caused by: java.net.ConnectException: Connection refused (Connection
> refused)*
> at java.net.PlainSocketImpl.socketConnect(Native Method)
> at java.net.AbstractPlainSocketImpl.doConnect(
> AbstractPlainSocketImpl.java:350)
> at java.net.AbstractPlainSocketImpl.connectToAddress(
> AbstractPlainSocketImpl.java:206)
> at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:
> 188)
> at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> at java.net.Socket.connect(Socket.java:589)
> at java.net.Socket.connect(Socket.java:538)
> at java.net.Socket.(Socket.java:434)
> at java.net.Socket.(Socket.java:211)
> at org.apache.ignite.internal.client.thin.TcpClientChannel.
> createSocket(TcpClientChannel.java:216)
> at org.apache.ignite.internal.client.thin.TcpClientChannel.<
> init>(TcpClientChannel.java:108)
> ... 7 more
>
>
>
> Scala Code:-
>
> 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.{ClientConfiguration, 
> IgniteConfiguration}
> 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 com.ignite.examples.model.Address
> import org.apache.ignite.client.{ClientCache, IgniteClient}
>
> import scala.collection.JavaConversions._
>
> object IgniteClientConnection {
>   def main(args: Array[String]): Unit = {
>
> System.*out*.println()
> System.*out*.println(">>> Thin client put-get example started.")
> System.*out*.println(">>> I am here.")
>
> val cfg2 = new 
> ClientConfiguration().setAddresses("100.25.173.220:47100..47700")
> val igniteClient:IgniteClient = Ignition.*startClient*(cfg2)
> val CACHE_NAME = "put-get-example";
> //val cache:ClientCache[Integer, Address] = 
> igniteClient.getOrCreateCache(CACHE_NAME)
>
> System.*out*.format(">>> Created cache [%s].\n", CACHE_NAME)
>
>
>
>   }
>
> }
>
>
>
> --
>
> Thanks & Regards
>
> Sri Tummala
>
>
>


-- 
Thanks & Regards
Sri Tummala

RE: Connection Refused in Scala Ignite Client (Help!)

2019-10-16 Thread alexanderkor12 
Hi,

   Try using the S3 IP Finder: 
https://apacheignite-mix.readme.io/docs/amazon-aws#section-amazon-s3-based-discovery

 

  



  



  

  



  



  

 

Thanks, Alex

 

 

From: sri hari kali charan Tummala  
Sent: Wednesday, October 16, 2019 5:55 PM
To: user@ignite.apache.org
Subject: Connection Refused in Scala Ignite Client (Help!)

 

Hi All, 

 

I am trying to connect my ignite cluster which is created on AWS (), now I am 
suing scala code to connect to the client which is failing with connection 
refused error.

 

In my security group I opened all the ports still I am having issues can anyone 
help.

 

Error:-

Exception in thread "main" org.apache.ignite.client.ClientConnectionException: 
Ignite cluster is unavailable
at 
org.apache.ignite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:114)
at 
org.apache.ignite.internal.client.thin.TcpIgniteClient.lambda$new$0(TcpIgniteClient.java:79)
at 
org.apache.ignite.internal.client.thin.ReliableChannel.(ReliableChannel.java:84)
at 
org.apache.ignite.internal.client.thin.TcpIgniteClient.(TcpIgniteClient.java:86)
at 
org.apache.ignite.internal.client.thin.TcpIgniteClient.start(TcpIgniteClient.java:205)
at org.apache.ignite.Ignition.startClient(Ignition.java:586)
at 
com.ignite.examples.igniteStartup.IgniteClientConnection$.main(IgniteClientConnection.scala:36)
at 
com.ignite.examples.igniteStartup.IgniteClientConnection.main(IgniteClientConnection.scala)
Caused by: java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at java.net.Socket.connect(Socket.java:538)
at java.net.Socket.(Socket.java:434)
at java.net.Socket.(Socket.java:211)
at 
org.apache.ignite.internal.client.thin.TcpClientChannel.createSocket(TcpClientChannel.java:216)
at 
org.apache.ignite.internal.client.thin.TcpClientChannel.(TcpClientChannel.java:108)
... 7 more

 

Scala Code:-

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.{ClientConfiguration, 
IgniteConfiguration}
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 com.ignite.examples.model.Address
import org.apache.ignite.client.{ClientCache, IgniteClient}

import scala.collection.JavaConversions._

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

System.out.println()
System.out.println(">>> Thin client put-get example started.")
System.out.println(">>> I am here.")

val cfg2 = new 
ClientConfiguration().setAddresses("100.25.173.220:47100..47700")
val igniteClient:IgniteClient = Ignition.startClient(cfg2)
val CACHE_NAME = "put-get-example";
//val cache:ClientCache[Integer, Address] = 
igniteClient.getOrCreateCache(CACHE_NAME)

System.out.format(">>> Created cache [%s].\n", CACHE_NAME)



  }

}

 

-- 

Thanks & Regards

Sri Tummala