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)
