我试图在emr集群上使用预训练keras模型对多个文件进行并行预测。我可以在主节点上加载模型并用它进行预测,但是当我尝试使用spark时,在尝试使用或访问模型时会出现错误“name'tf'is not defined”。
到目前为止,我已经尝试了以下解决方案,它们都会产生相同的错误:
我试过用lambda Package 器传递模型。
我用sc广播模型
我在所有节点上下载了model.h5,并对每个分区使用load\ u模型。对于load\u model,我使用了自定义的\u objects={tf':tf}解决方案,并且在加载模型的 Package 函数中导入tensorflow作为tf。
所有的解决方案都不起作用。有没有人有过类似的经历?我使用r5示例作为主节点,m5示例作为节点。
暂无答案!
目前还没有任何答案,快来回答吧!