Как запросить воспламенение кеша по java? - PullRequest
Новая
       88

Как запросить воспламенение кеша по java?

0 голосов
/ 17 марта 2020

Я запускаю сервер зажигания с помощью ./ignite.sh, запускаю клиент зажигания с помощью кода java и выполняю запрос в java, 

public class TOFListener {
public static void main(String[] args) {
    IgniteConfiguration cfg = new IgniteConfiguration();
    cfg.setClientMode(true);
    //cfg.setPeerClassLoadingEnabled(true);

    Ignite ignite = Ignition.start(cfg);
    IgniteCache<String, Object> cache = ignite.getOrCreateCache("TOFCache");
    ContinuousQuery<String, Object> qry = new ContinuousQuery<>();
    qry.setInitialQuery(new ScanQuery<>((k, v) -> "name".equals(k) || "shoulderWidthStdDev".equals(k)));
    qry.setLocalListener((evts) -> evts.forEach(e ->
            System.out.println("UpdatedValue, [key=" + e.getKey() + ", val=" + e.getValue() + "]")));
    qry.setRemoteFilterFactory(() -> evts -> evts.getKey().equals("name") || evts.getKey().equals("shoulderWidthStdDev"));

    cache.query(qry);

}

}

но возникает исключение, как это: Exception01 Exception02 Exception03

Но когда я запускаю сервер с помощью кода java, запрос в порядке Не знаю почему, кто-нибудь может мне помочь? Спасибо ...

1 Ответ

0 голосов
/ 18 марта 2020

Класс отсутствует на узле сервера, поэтому ваши лямбды не могут быть созданы там.

Вы должны либо включить Загрузка класса равноправных узлов , либо развернуть свой код на узлах сервера в виде JAR.

...