我试图在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示例作为节点。