Как выполнять задания Jet, присоединившись к другому узлу? - PullRequest
0 голосов
/ 11 июня 2018

Привет, у меня проблема с самолетом Hazelcast.

У меня есть приложение, которое запускает два узла в 127.0.0.1:5701, 127.0.0.1:5702.Когда я запускаю приложение, оно создает DAG и получает требуемый результат.Если я пытаюсь подключить другой экземпляр hazelcast jet, скажем 127.0.0.1:5703 из другого источника (не из приложения), узлы изначально объединяются, но выдает ошибку сериализации, например

com.hazelcast.nio.serialization.HazelcastSerializationException: java.lang.ClassCastException: невозможно назначить экземпляр java.lang.invoke.SerializedLambda для поля com.hazelcast.jet.core.processor.SourceProcessors.

Для всей конфигурации был включен tcp-ip, поэтому я могу присоединиться к обоим узлам.

Я также попытался сначала запустить внешний узел, а затем приложение или наоборот, оба вывели ту же ошибку.Я хотел бы знать, как правильно настроить внешний узел для заданий.Версия Jet 0.6.1

Заранее спасибо

...