CreateDirectStream.foreachRDD error calling external object

the figure is as follows:
clipboard.png

def update_model(rdd),mixture_model:

clipboard.png

it"s OK to declare mixture_model directly in update_model, but every time you foreachRDD, you need to re-declare MingleModel. Makes it impossible to update the model in real time


false reading feels like there is no way to serialize read and write in mixture_model

MySQL Query : SELECT * FROM `codeshelper`.`v9_news` WHERE status=99 AND catid='6' ORDER BY rand() LIMIT 5
MySQL Error : Disk full (/tmp/#sql-temptable-64f5-1b32999-2be55.MAI); waiting for someone to free some space... (errno: 28 "No space left on device")
MySQL Errno : 1021
Message : Disk full (/tmp/#sql-temptable-64f5-1b32999-2be55.MAI); waiting for someone to free some space... (errno: 28 "No space left on device")
Need Help?