This closes #1920

apache · Feb 5, 2017 · e5afbb2 · e5afbb2
2 parents 6e220bb + 25f9135
commit e5afbb2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...rs/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java b/...rs/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java
@@ -62,8 +62,10 @@ Iterable<OutputT> processPartition(
 
     // skip if partition is empty.
     if (!partition.hasNext()) {
+      DoFnInvokers.invokerFor(doFn).invokeTeardown();
       return Lists.newArrayList();
     }
+
     // call startBundle() before beginning to process the partition.
     doFnRunner.startBundle();
     // process the partition; finishBundle() is called from within the output iterator.