Hi Beam community, We are running an unbounded pipeline with Flink runner, is there any method we can stop/cancel pipeline in pipeline code? Will this be enabled if issue https://issues.apache.org/jira/browse/BEAM-593 <https://issues.apache.org/jira/browse/BEAM-593> is resolved? Thanks for any responses.
Thanks, Yu
