[jira] [Created] (FLINK-5955) Merging a list of buffered records will have problem when ObjectReuse is turned on

[Shang Yuanchun (Jira)]

Shaoxuan Wang created FLINK-5955:
------------------------------------

             Summary: Merging a list of buffered records will have problem when ObjectReuse is turned on
                 Key: FLINK-5955
                 URL: https://issues.apache.org/jira/browse/FLINK-5955
             Project: Flink
          Issue Type: Bug
            Reporter: Shaoxuan Wang
            Assignee: Shaoxuan Wang


Turn on ObjectReuse in MultipleProgramsTestBase:
TestEnvironment clusterEnv = new TestEnvironment(cluster, 4, true);

Then the tests "testEventTimeSessionGroupWindow", "testEventTimeSessionGroupWindow", and "testEventTimeTumblingGroupWindowOverTime"  will fail.

The reason is that we have buffered iterated records for group-merge. I think we should change the Agg merge to pair-merge, and later add group-merge when needed (in the future we should add rules to select either pair-merge or group-merge, but for now all built-in aggregates should work fine with pair-merge).



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)