14/09/17 14:21:21 ERROR storage.DiskBlockManager: Exception while deleting local spark dir: C:\Users\Steve\AppData\Local\Temp\spark-local-20140917142115-6a81 java.io.IOException: Failed to delete: C:\Users\Steve\AppData\Local\Temp\spark-local-20140917142115-6a81\03\shuffle_0_0_10
I run a job with Spark 1.1 involving a mapPartitions. When I add a collect step to force evaluation I get the above error. What am I doing wrong? I am running on a local master