Thanks Ruoyun! For Flink, we use a different job server which you can start using "./gradlew beam-runners-flink_2.11-job-server:runShadow " The host:port for this jobserver is localhost:8099
On Mon, Dec 3, 2018 at 2:24 PM Ruoyun Huang <[email protected]> wrote: > Maybe this helps: > https://cwiki.apache.org/confluence/display/BEAM/Usage+Guide > > On Mon, Dec 3, 2018 at 2:10 PM [email protected] < > [email protected]> 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 > >
