[jira] [Created] (FLINK-20698) A single ojbect is reused among windows with different key

[Shang Yuanchun (Jira)]

Yordan Pavlov created FLINK-20698:
-------------------------------------

             Summary: A single ojbect is reused among windows with different key
                 Key: FLINK-20698
                 URL: https://issues.apache.org/jira/browse/FLINK-20698
             Project: Flink
          Issue Type: Bug
          Components: API / Core
    Affects Versions: 1.10.1
            Reporter: Yordan Pavlov
         Attachments: VariablesNotCreatedPerKey.scala

When a stream is keyed and time window applied, a single object is being reused among the different keyed streams. I am pasting the essence of my test code with the full version attached.


{code:scala}
    source
      .keyBy( x => x.elementNumber)
      .timeWindow(Time.milliseconds(1))
      .apply(new WindowCounter())
{code}

In this example a single WindowCounter object is being created. Please correct me if this is not really a bug.




--
This message was sent by Atlassian Jira
(v8.3.4#803005)