flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (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:15:27 GMT

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

Aljoscha Krettek commented on FLINK-2891:

I think right now it is state/key for the window function because they just use the same state
interface that all user functions use and they are not aware of windows. I think this is good,
since you can keep state across windows in the window evaluation function.

For triggers the state is per key/window.

> 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