[
https://issues.apache.org/jira/browse/BEAM-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546412#comment-15546412
]
Pei He commented on BEAM-702:
-
1. If there are failures in one bundle, we can easily call teardown()s of DoFns
[
https://issues.apache.org/jira/browse/BEAM-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546411#comment-15546411
]
Pei He commented on BEAM-702:
-
1. If there are failures in one bundle, we can easily call teardown()s of DoFns
[
https://issues.apache.org/jira/browse/BEAM-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546300#comment-15546300
]
Eugene Kirpichov commented on BEAM-702:
---
Hmm, I didn't realize that we don't call finishBundle and
[
https://issues.apache.org/jira/browse/BEAM-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546277#comment-15546277
]
Pei He commented on BEAM-702:
-
The feature request is for something like this?
class MyDoFn extends DoFn
[
https://issues.apache.org/jira/browse/BEAM-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15543109#comment-15543109
]
Eugene Kirpichov commented on BEAM-702:
---
CC: [~tgroh]
> Simple pattern for per-bundle and per-DoFn