createDirectStream.foreachRDD调用外部对象出错

如下图:
clipboard.png

def update_model(rdd),调用外部声明的mixture_model会出现如下错误:

clipboard.png

直接在update_model中声明 ·mixture_model·是没有问题的,但是每次foreachRDD时,都需要从新声明一次MingleModel。导致无法实时更新模型

阅读 3k
1 个回答

看报错感觉是mixture_model中没有提供序列化读写的方法

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题