Databases
StackOverflow2013
Postsdbo
POTargetNotAMemberException while executing a task using distributed executor service - hazelcast
 

Note that there are some explanatory texts on larger screens.

plurals
  1. POTargetNotAMemberException while executing a task using distributed executor service - hazelcast
    primarykey
    data
    text
    <p>I am trying to use the distributed executor service for hazelcast 3.1 and find that i am unable to use submitToMember(<strong>task,member</strong>). In my example below 10.69.108.60 is my local machine and 170.194.100.111 is my remote machine. I am able to get return value in my future when the <strong>member</strong> is my local machine but gives me a <strong>TargetNotAMemberException</strong> if the <strong>member</strong> is remote machine. Below is the code</p> <pre><code>public class DistExecutionTest { public static void main(String args[]){ DistributedExecutor dex = new DistributedExecutor(); try { Member member = new MemberImpl(new Address("170.194.100.111",5701), false ); String msg; msg = dex.echoOnTheMember("Hey youuuu!", member); System.out.println(msg); } catch (UnknownHostException e1) { e1.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); }catch (Exception e) { e.printStackTrace(); } } } </code></pre> <p>and</p> <pre><code>public class DistributedExecutor { Config config; NetworkConfig network; JoinConfig join; DistributedExecutor(){ config = new Config(); network = config.getNetworkConfig(); // network.setPort(5701); join = network.getJoin(); join.getMulticastConfig().setEnabled(false); join.getTcpIpConfig().addMember("170.194.100.111").addMember("10.69.108.60").setEnabled(true); network.getInterfaces().setEnabled(true).addInterface("170.194.100.*").addInterface("10.69.108.*"); } public String echoOnTheMember(String input, Member member) throws Exception { Callable&lt;String&gt; task = new DistObject(input); HazelcastInstance hz = Hazelcast.newHazelcastInstance(config); IExecutorService executorService = hz.getExecutorService("default"); Future&lt;String&gt; future = executorService.submitToMember(task, member); String distObjectResult = future.get(); return distObjectResult; } } </code></pre> <p>and</p> <pre><code>public class Echo implements Callable&lt;String&gt;, Serializable, HazelcastInstanceAware { private static final long serialVersionUID = -3164053990811643392L; String message = null; transient HazelcastInstance localInstance; public Echo(String msg){ message = msg; } @Override public String call() throws Exception { return localInstance.toString() + message; } @Override public void setHazelcastInstance(HazelcastInstance hazelcastInstance) { this.localInstance = hazelcastInstance; } } </code></pre> <p>Here is the logging on local machine</p> <pre><code>Dec 17, 2013 1:03:20 PM com.hazelcast.instance.DefaultAddressPicker INFO: Interfaces is enabled, trying to pick one address matching to one of: [162.124.194.*, 10.38.148.*] Dec 17, 2013 1:03:20 PM com.hazelcast.instance.DefaultAddressPicker INFO: Prefer IPv4 stack is true. Dec 17, 2013 1:03:20 PM com.hazelcast.instance.DefaultAddressPicker INFO: Picked Address[10.69.108.60]:5701, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5701], bind any local is true Dec 17, 2013 1:03:21 PM com.hazelcast.system INFO: [10.69.108.60]:5701 [dev] Hazelcast Community Edition 3.1 (20131011) starting at Address[10.69.108.60]:5701 Dec 17, 2013 1:03:21 PM com.hazelcast.system INFO: [10.69.108.60]:5701 [dev] Copyright (C) 2008-2013 Hazelcast.com Dec 17, 2013 1:03:21 PM com.hazelcast.instance.Node INFO: [10.69.108.60]:5701 [dev] Creating TcpIpJoiner Dec 17, 2013 1:03:21 PM com.hazelcast.core.LifecycleService INFO: [10.69.108.60]:5701 [dev] Address[10.69.108.60]:5701 is STARTING Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[10.69.108.60]:5703 Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[10.69.108.60]:5702 Dec 17, 2013 1:03:21 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Connecting to /10.69.108.60:5703, timeout: 0, bind-any: true Dec 17, 2013 1:03:21 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Connecting to /10.69.108.60:5702, timeout: 0, bind-any: true Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[170.194.100.111]:5703 Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[170.194.100.111]:5702 Dec 17, 2013 1:03:21 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Connecting to /170.194.100.111:5703, timeout: 0, bind-any: true Dec 17, 2013 1:03:21 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Connecting to /170.194.100.111:5702, timeout: 0, bind-any: true Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[170.194.100.111]:5701 Dec 17, 2013 1:03:21 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Connecting to /170.194.100.111:5701, timeout: 0, bind-any: true Dec 17, 2013 1:03:22 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Could not connect to: /10.69.108.60:5703. Reason: SocketException[Connection refused: connect to address /10.69.108.60:5703] Dec 17, 2013 1:03:22 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Could not connect to: /10.69.108.60:5702. Reason: SocketException[Connection refused: connect to address /10.69.108.60:5702] Dec 17, 2013 1:03:22 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Could not connect to: /170.194.100.111:5703. Reason: SocketException[Connection refused: connect to address /170.194.100.111:5703] Dec 17, 2013 1:03:22 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Could not connect to: /170.194.100.111:5702. Reason: SocketException[Connection refused: connect to address /170.194.100.111:5702] Dec 17, 2013 1:03:22 PM com.hazelcast.nio.SocketConnector INFO: [10.69.108.60]:5701 [dev] Could not connect to: /170.194.100.111:5701. Reason: SocketException[Connection refused: connect to address /170.194.100.111:5701] Dec 17, 2013 1:03:23 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Members [1] { Member [10.69.108.60]:5701 this } Dec 17, 2013 1:03:23 PM com.hazelcast.core.LifecycleService INFO: [10.69.108.60]:5701 [dev] Address[10.69.108.60]:5701 is STARTED HazelcastInstance{name='_hzInstance_1_dev', node=Address[10.69.108.60]:5701}Hey youuuu! </code></pre> <p>The logging on the remote machine is on these lines.Couldnt paste all the logging.Managed to get the important part.</p> <pre><code> INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[10.38.148.60]:5703 Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[10.38.148.60]:5702 Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[10.38.148.60]:5701 Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[170.194.100.111]:5703 Dec 17, 2013 1:03:21 PM com.hazelcast.cluster.TcpIpJoiner INFO: [10.69.108.60]:5701 [dev] Connecting to possible member: Address[170.194.100.111]:5702 Dec 17, 2013 1:03:21 PM com.hazelcast.nio.SocketConnector Members [2] { Member [10.69.108.60]:5701 this Member [170.194.100.111]:5701 } </code></pre>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PTQuestion
    1. USAnusha Pachunuri
    1. USAnusha Pachunuri
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. PO
      singulars
      1. PTAnswer
    2. PO
      singulars
      1. PTAnswer
    1. This table or related slice is empty.
    1. COIt seems that your cluster is forming. Do you see in the other console also Members[2] {....}?
      singulars
      1. POTargetNotAMemberException while executing a task using distributed executor service - hazelcast
      1. USpveentjer
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload