[
https://issues.apache.org/jira/browse/BEAM-235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305410#comment-15305410
]
ASF GitHub Bot commented on BEAM-235:
-
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/395
[Beam-312] don't checkpoint if CheckpointCoder not available
This skips the checkpoint logic in the UnboundedSourceWrapper if the
UnboundedSource doesn't supply a CheckpointMarkCoder.
You
GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/394
[BEAM-235] use streaming mode on unbounded sources
This change automatically discovers the execution mode of the Pipeline
during a preliminary "optimization" translation of the pipeline.
Maximilian Michels created BEAM-312:
---
Summary: UnboundedSourceWrapper fails if CheckpointMarkCoder not
available
Key: BEAM-312
URL: https://issues.apache.org/jira/browse/BEAM-312
Project: Beam