[beam] 03/12: Invoke finishBundle() before teardown() in DoFnOperator

[aljoscha]

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 4029e23f3075365eddcdad5187b4fc8a6e590989
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
AuthorDate: Fri Jan 5 14:22:40 2018 +0100

    Invoke finishBundle() before teardown() in DoFnOperator
---
 .../runners/flink/translation/wrappers/streaming/DoFnOperator.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
 
b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
index 2e7f741..688a7cb 100644
--- 
a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
+++ 
b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
@@ -363,6 +363,9 @@ public class DoFnOperator<InputT, OutputT>
       super.dispose();
       checkFinishBundleTimer.cancel(true);
     } finally {
+      if (bundleStarted) {
+        invokeFinishBundle();
+      }
       doFnInvoker.invokeTeardown();
     }
   }

-- 
To stop receiving notification emails like this one, please contact
aljos...@apache.org.