0

嗨,我对 Hazelcast jet 有疑问。

我有一个应用程序在 , 中启动两个127.0.0.1:5701节点127.0.0.1:5702。当我运行应用程序时,它会创建 DAG 并获得所需的输出。如果我试图127.0.0.1:5703从另一个来源(而不是来自应用程序)连接 hazelcast jet 的另一个实例,则节点最初会加入但会引发序列化错误,例如

com.hazelcast.nio.serialization.HazelcastSerializationException:java.lang.ClassCastException:无法将 java.lang.invoke.SerializedLambda 的实例分配给字段 com.hazelcast.jet.core.processor.SourceProcessors。

所有配置均已启用 tcp-ip,因此我可以加入两个节点。

我还尝试先启动外部节点然后启动应用程序,反之亦然,两者都产生了相同的错误。我想知道为作业配置外部节点的正确方法是什么。喷气机版本0.6.1

提前致谢

4

0 回答 0