[FLINK-20698] A single object is reused among windows with different key

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.10.1
• Component/s: API / Core
• Assignee: Unassigned
• Reporter: Yordan Pavlov
• Created: 21/Dec/20 12:39
• Updated: 21/Dec/20 17:01
• Resolved: 21/Dec/20 15:58

Description

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.

    source
      .keyBy( x => x.elementNumber)
      .timeWindow(Time.milliseconds(1))
      .apply(new WindowCounter())

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