[ https://issues.apache.org/jira/browse/BEAM-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733714#comment-16733714 ]
Chen Zhiling edited comment on BEAM-593 at 1/4/19 1:41 AM: ----------------------------------------------------------- That's great to hear! Thanks [~mxm] :) was (Author: zhilingc): Great news. Thanks [~mxm] :) > Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in > FlinkRunnerResult > ----------------------------------------------------------------------------------------------- > > Key: BEAM-593 > URL: https://issues.apache.org/jira/browse/BEAM-593 > Project: Beam > Issue Type: New Feature > Components: runner-flink > Reporter: Pei He > Assignee: Aljoscha Krettek > Priority: Major > Time Spent: 1h > Remaining Estimate: 0h > > We introduced both functions to PipelineResult. > Currently, both of them throw UnsupportedOperationException in Flink runner. -- This message was sent by Atlassian JIRA (v7.6.3#76005)