[ https://issues.apache.org/jira/browse/BEAM-492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Amit Sela updated BEAM-492: --------------------------- Fix Version/s: 0.3.0-incubating > Spark runner should call Pipeline.run() instead of SparkRunner.run() > -------------------------------------------------------------------- > > Key: BEAM-492 > URL: https://issues.apache.org/jira/browse/BEAM-492 > Project: Beam > Issue Type: Bug > Affects Versions: 0.1.0-incubating > Reporter: Amit Sela > Assignee: Amit Sela > Fix For: 0.3.0-incubating > > > Currently, in some places (streaming examples, etc.), the Pipeline executes > by calling SparkRunner.run() instead of calling Pipeline.run() which is kind > of "backwards" to the Beam API. -- This message was sent by Atlassian JIRA (v6.3.4#6332)