nguyenign

i have the same problem, spark context is not initialized, i had to create it manually outside of spark celery but it's not a good idea.

Hi All, In the function worker_init(self, loader), we need a loader. Can you please tell me what is loader ? I have an error when i call this function def...

Thank you very much for your solution. I tried it but i still have a problem, i need the spark context in registed task to broadcast some database file but...