I just realized that saying "local" is a bad idea because "local" ends up having only one slot, which is bad for Spark Streaming (as receiver takes up one core leaving none for computation). Can you replace this `local` with `local[*]` (which detects the number of cores in the local system).