[jira] [Commented] (BEAM-485) Can't set Flink runner in code

[ https://issues.apache.org/jira/browse/BEAM-485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15716711#comment-15716711 ] Emanuele Cesena commented on BEAM-485: -- I didn’t really had the chance to try, but if i

[jira] [Created] (BEAM-485) Can't set Flink runner in code

Emanuele Cesena created BEAM-485: Summary: Can't set Flink runner in code Key: BEAM-485 URL: https://issues.apache.org/jira/browse/BEAM-485 Project: Beam Issue Type: Bug Components:

[jira] [Updated] (BEAM-333) Support "stop" for streaming pipelines

[ https://issues.apache.org/jira/browse/BEAM-333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Emanuele Cesena updated BEAM-333: - Description: Run: {code} $ flink run -c org.apache.beam.runners.flink.examples.streaming.KafkaWindo

[jira] [Created] (BEAM-333) Support "stop" for streaming pipelines

Emanuele Cesena created BEAM-333: Summary: Support "stop" for streaming pipelines Key: BEAM-333 URL: https://issues.apache.org/jira/browse/BEAM-333 Project: Beam Issue Type: Bug Com