Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
10-13-2022 06:59 AM
I may have figured this out!
I'm explicitly setting the number of slices instead of using the default.
days_rdd = sc.parallelize(days_to_process,len(days_to_process))