flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gerard Garcia (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7731) Trigger on GlobalWindow does not clean state completely
Date Thu, 28 Sep 2017 14:12:03 GMT
Gerard Garcia created FLINK-7731:
------------------------------------

             Summary: Trigger on GlobalWindow does not clean state completely
                 Key: FLINK-7731
                 URL: https://issues.apache.org/jira/browse/FLINK-7731
             Project: Flink
          Issue Type: Bug
          Components: Core, DataStream API
    Affects Versions: 1.3.2
            Reporter: Gerard Garcia
            Priority: Minor


I have an operator that consists of:

CoGroup Datastream -> GlobalWindow -> CustomTrigger -> Apply function

The custom trigger fires and purges the elements after it has received the expected number
of elements (or when a timeout fires) from one of the streams and the apply function merges
the elements with the ones received from the other stream. It appears that the state of the
operator grows continuously so it seems it never gets completely cleaned.

There is a discussion in http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Clean-GlobalWidnow-state-td15613.html
that suggests that it may be a bug.

This job reproduces the issue: https://github.com/GerardGarcia/flink-global-window-growing-state



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message