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
