Maybe this helps: https://cwiki.apache.org/confluence/display/BEAM/Usage+Guide
On Mon, Dec 3, 2018 at 2:10 PM sai.inamp...@gmail.com < sai.inamp...@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
