flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5955) Merging a list of buffered records will have problem when ObjectReuse is turned on
Date Sun, 05 Mar 2017 05:17:32 GMT

    [ https://issues.apache.org/jira/browse/FLINK-5955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896065#comment-15896065
] 

ASF GitHub Bot commented on FLINK-5955:
---------------------------------------

Github user shaoxuan-wang closed the pull request at:

    https://github.com/apache/flink/pull/3464


> 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
>          Components: Table API & SQL
>            Reporter: Shaoxuan Wang
>            Assignee: Shaoxuan Wang
>             Fix For: 1.3.0
>
>
> 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)

Mime
View raw message