[01:34:23] REST protocols do not start on client node. To start the protocols
on client node set '-DIGNITE_REST_START_ON_CLIENT=true' system property.
[01:34:23] Failed to connect to any address from IP finder (will retry to
join topology every 2 secs): [/10.133.71.210:47500]
[01:39:24] Failed to connect to any address from IP finder (will retry to
join topology every 2 secs): [/10.133.71.210:47500]
[01:44:24] Failed to connect to any address from IP finder (will retry to
join topology every 2 secs): [/10.133.71.210:47500]
[01:49:24] Failed to connect to any address from IP finder (will retry to
join topology every 2 secs): [/10.133.71.210:47500]
My code:
-----------
TcpDiscoverySpi tcpDiscoverySpi = new TcpDiscoverySpi();
TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
List<String> addressList = new ArrayList<>();
addressList.add("10.133.71.210:47500");
//addressList.add("127.0.0.1:47501");
/*
* addressList.add("127.0.0.1:47502");
* addressList.add("127.0.0.1:47503");
* addressList.add("127.0.0.1:47504");
addressList.add("localhost");
*/
ipFinder.setAddresses(addressList);
tcpDiscoverySpi.setIpFinder(ipFinder);
tcpDiscoverySpi.setLocalAddress("10.133.71.210");
/*
* OptimizedMarshaller optimize = new OptimizedMarshaller();
* optimize.setRequireSerializable(false);
*/
IgniteConfiguration cfg = new IgniteConfiguration();
//cfg.setLocalHost("10.133.71.210");
cfg.setClientMode(true);
//cfg.setre
//cfg.setPeerClassLoadingEnabled(false);
/*
* cfg.setMarshaller(optimize); cfg.setMarshaller(optimize);
*/
cfg.setDiscoverySpi(tcpDiscoverySpi);
Ignite ignite = Ignition.start(cfg);
//Ignite ignite =
Ignition.start("C:/Doc/apache-ignite-fabric-2.0.0-bin/examples/config/example-ignite.xml");
IgniteCache<Integer, String> cache = ignite.cache(CACHE_NAME);
IgniteCompute asyncCompute = ignite.compute().withAsync();
List<IgniteFuture<?>> futs = new ArrayList<>();
for (int i = 0; i < KEY_CNT; i++) {
final int key = i;
// This closure will execute on the remote node where
// data with the 'key' is located.
asyncCompute.affinityRun(CACHE_NAME, key, new
IgniteRunnable() {
@Override public void run() {
// Peek is a local memory lookup.
System.out.println("Co-located [key= " + key + ",
value= " +
cache.get(key) +']');
}
});
}
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Connecting-to-remote-host-from-client-gives-error-tp14395.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
