flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4828) execute stream job asynchronously
Date Fri, 14 Oct 2016 09:48:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15574839#comment-15574839

Stephan Ewen commented on FLINK-4828:

I think this is a special case of that issue: https://issues.apache.org/jira/browse/FLINK-2313

> execute stream job asynchronously
> ---------------------------------
>                 Key: FLINK-4828
>                 URL: https://issues.apache.org/jira/browse/FLINK-4828
>             Project: Flink
>          Issue Type: New Feature
>          Components: DataStream API
>            Reporter: David Anderson
> It is currently awkward to work with datastreams in a notebook (e.g. Zeppelin or Jupyter)
because env.execute() never returns, and there is no way to control the job that has been
started. It would be much better to have a variant like env.executeAsync() that executes the
job in another thread, and returns right away. This method should return an object that can
be used to cancel or stop the job.

This message was sent by Atlassian JIRA

View raw message