Details
-
Bug
-
Resolution: Incomplete
-
Major
-
None
-
None
-
None
Description
When code like
sc.parallelize(Seq(JsonDocument.create("foo", JsonObject.empty())), 2).saveToCouchbase(targetBucket)
is done it works against 2 workers, but when you do
sc.parallelize(Seq(JsonDocument.create("foo", JsonObject.empty())), 1).saveToCouchbase(targetBucket)
the application is done but the stage never completes (and therefore the job is always running).