我遍历了IgniteContext的代码,在所有执行程序节点上都使用了部署ignite的模式,我发现在spark context parallize方法的帮助下,将ignite实例内部部署在所有执行程序中,使用spark事件侦听器停止了ignite实例。 (即在应用程序结束时)。我不知道是否在动态添加的火花执行器上部署了ignite?我在IgniteContext中找不到任何此类代码。可以对此发表评论吗?
另外,它附加一个事件侦听器,以检查是否产生了新的执行程序节点,以及是否再次产生在该节点上运行相同的任务。在应用程序端,它将停止点燃实例。