Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
05-12-2023 01:26 AM
This is because multiprocessing will not use the distributed framework of spark/databricks.
When you use that, your code will run on the driver only and the workers are not doing anything.
More info here.
So you should use a spark-enabled ML library, like sparktorch.
Or do not use spark but Ray for example:
https://docs.databricks.com/machine-learning/ray-integration.html