beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ruoyun Huang <ruo...@google.com>
Subject Re: How to kick off a Beam pipeline with PortableRunner in Java?
Date Mon, 03 Dec 2018 22:23:54 GMT
Maybe this helps:
https://cwiki.apache.org/confluence/display/BEAM/Usage+Guide

On Mon, Dec 3, 2018 at 2:10 PM sai.inampudi@gmail.com <
sai.inampudi@gmail.com> wrote:

> Hi everyone,
>
> Can someone point me to how to kick off a Beam pipeline using the
> PortableRunner (w/Flink) in Java? I saw some examples in Python but I
> haven't been able to find any for Java.
>
> I tried to modify the runner option to use PortableRunner but I get the
> following error below:
> java.lang.IllegalArgumentException: Unknown 'runner' specified
> 'PortableRunner', supported pipeline runners [DirectRunner, FlinkRunner,
> SparkRunner, TestFlinkRunner, TestSparkRunner]
>
> For reference, I am on Beam 2.8.0 and the reason I want to try to use the
> PortableRunner is so I can confirm a comment[1] in BEAM-593 that states
> that pipeline.run() is no longer a blocking call in the PortableRunner with
> Flink.
>
> [1]
> https://issues.apache.org/jira/browse/BEAM-593?focusedCommentId=16618916&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16618916
>


-- 
================
Ruoyun  Huang

Mime
View raw message