flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation
Date Thu, 22 Oct 2015 06:18:27 GMT

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

Gyula Fora commented on FLINK-2891:

Then it's probably hard to keep state only in the window. In a window apply you this is possible
because you call it on a new window everytime but on a reducer this becomes tricky. I guess
this is a tradeoff at the moment.

> Key for Keyed State is not set upon Window Evaluation
> -----------------------------------------------------
>                 Key: FLINK-2891
>                 URL: https://issues.apache.org/jira/browse/FLINK-2891
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Streaming
>    Affects Versions: 0.10
>            Reporter: Aljoscha Krettek
>            Assignee: Aljoscha Krettek
>            Priority: Blocker
>             Fix For: 0.10
> In both the aligned and the general-purpose windows the key for the keyed operator state
is not set when evaluating the windows. This silently leads to incorrect results.

This message was sent by Atlassian JIRA

View raw message