flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1425) Turn lazy operator execution off for streaming programs
Date Fri, 23 Jan 2015 14:12:34 GMT

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

ASF GitHub Bot commented on FLINK-1425:

GitHub user uce opened a pull request:


    [FLINK-1425] [streaming] Add scheduling of all tasks at once

    See corresponding [discussion](http://mail-archives.apache.org/mod_mbox/incubator-flink-dev/201501.mbox/%3CCA%2Bfaj9yHzsNDW-6hUVdoL_OY0EoVMRrEO-6fWjyD9A_oJsxvnA%40mail.gmail.com%3E)
on the mailing list.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/uce/incubator-flink schedule-all

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #330
commit 1f82e0fe8eed1947f95aa2e5d276a1432171a187
Author: Ufuk Celebi <uce@apache.org>
Date:   2015-01-23T10:30:30Z

    [FLINK-1425] [streaming] Add scheduling of all tasks at once


> Turn lazy operator execution off for streaming programs
> -------------------------------------------------------
>                 Key: FLINK-1425
>                 URL: https://issues.apache.org/jira/browse/FLINK-1425
>             Project: Flink
>          Issue Type: Task
>          Components: Streaming
>    Affects Versions: 0.9
>            Reporter: Gyula Fora
>            Assignee: Ufuk Celebi
> Streaming programs currently use the same lazy operator execution model as batch programs.
This makes the functionality of some operators like time based windowing very awkward, since
they start computing windows based on the start of the operator.
> Also, one should expect for streaming programs to run continuously so there is not much
to gain from lazy execution.

This message was sent by Atlassian JIRA

View raw message