hazelcast - すべてのメンバーで実行される HazelcastGrid Computing EntryProcessor

Question

EntryProcessor または ExecutorService を使用した hazelcast に問題があります。キーがどのメンバーにも存在しない場合、プロセッサは引き続き各ノードで実行されますが、その理由がわかりません。

プロセッサは null へのキー エントリを受け取ります。

いくつかのコードで更新

    //example of IMap executeOnKeys
    Map<?, ?> map = getCache().executeOnKeys(keys, processor);

    //example using executor service
    Future<Object[]> result = executor.submitToKeyOwner(myCallable, key);

プロセッサ

public class MyProcessor implements EntryProcessor<MyKey, MyValue>, Serializable {
...code
}

呼び出し可能

public class MyCallable implements Callable<Object[]>, Serializable {
...code
}

2 つの例では、クラスターのすべてのノードが要求を受信します。彼らがキーを持っていない場合、プロセスがトリガーされ、それが問題です。

クラスターの一部である Lite メンバーからリクエストを送信しています。

ありがとう、