[jira] [Commented] (BEAM-235) Remove streaming flag

2016-05-28 Thread ASF GitHub Bot (JIRA)
[ 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] incubator-beam pull request: [Beam-312] don't checkpoint if Checkp...

2016-05-28 Thread mxm
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] incubator-beam pull request: [BEAM-235] use streaming mode on unbo...

2016-05-28 Thread mxm
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.

[jira] [Created] (BEAM-312) UnboundedSourceWrapper fails if CheckpointMarkCoder not available

2016-05-28 Thread Maximilian Michels (JIRA)
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