[jira] [Comment Edited] (FLINK-21684) Fix typo in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297885#comment-17297885 ] wangpeibin edited comment on FLINK-21684 at 3/9/21, 7:39 AM: -

[jira] [Commented] (FLINK-21684) Fix typo in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297885#comment-17297885 ] wangpeibin commented on FLINK-21684: I have create this pr [https://github.com/apach

[jira] [Created] (FLINK-21684) Fix typo in StreamExecDeduplicate

wangpeibin created FLINK-21684: -- Summary: Fix typo in StreamExecDeduplicate Key: FLINK-21684 URL: https://issues.apache.org/jira/browse/FLINK-21684 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278643#comment-17278643 ] wangpeibin commented on FLINK-21203: hi [~jark] & [~Leonard Xu]  , Could you have a

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276366#comment-17276366 ] wangpeibin commented on FLINK-21203: If the config option is needed. It may be like

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276078#comment-17276078 ] wangpeibin commented on FLINK-21203: +1 for Jark's suggestion > Don’t collect -U&+

[jira] [Updated] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-21203: --- Description: In the  LastRowFunction , the -U&+U Row will be collected even if they are the same, w

[jira] [Updated] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-21203: --- Description: In the  LastRowFunction , the -U&+U Row will be collected even if they are the same, w

[jira] [Comment Edited] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274388#comment-17274388 ] wangpeibin edited comment on FLINK-21203 at 1/29/21, 12:16 PM: ---

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274388#comment-17274388 ] wangpeibin commented on FLINK-21203: It's my pleasure to work on this. Could you ass

[jira] [Updated] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-21203: --- Description: In the  LastRowFunction , the -U&+U Row will be collect  Even if they are the same, wh

[jira] [Updated] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-21203: --- Description: In the  LastRowFunction , the -U&+U Row will be collect  Even if they are the same, wh

[jira] [Updated] (FLINK-21202) Introduce TimeWindow and CountWindow in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-21202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-21202: --- Description: Now, when the lastrow function is used for de duplication, if two successive rows are

[jira] [Created] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

wangpeibin created FLINK-21203: -- Summary: Don’t collect -U&+U Row When they are equals In the LastRowFunction Key: FLINK-21203 URL: https://issues.apache.org/jira/browse/FLINK-21203 Project: Flink

[jira] [Updated] (FLINK-18441) support Local-Global Aggregation with LastValue Funciton

[ https://issues.apache.org/jira/browse/FLINK-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-18441: --- Description: The optimization of Local-Global Aggregation is invalid when the last_value aggregatio

[jira] [Updated] (FLINK-18441) support Local-Global Aggregation with LastValue Funciton

[ https://issues.apache.org/jira/browse/FLINK-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-18441: --- Attachment: image-2020-06-28-16-15-38-173.png > support Local-Global Aggregation with LastValue Func

[jira] [Updated] (FLINK-18441) support Local-Global Aggregation with LastValue Funciton

[ https://issues.apache.org/jira/browse/FLINK-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-18441: --- Description: The optimization of Local-Global Aggregation is invalid when the last_value aggregatio

[jira] [Updated] (FLINK-18441) support Local-Global Aggregation with LastValue Funciton

[ https://issues.apache.org/jira/browse/FLINK-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-18441: --- Attachment: image-2020-06-28-16-12-39-156.png > support Local-Global Aggregation with LastValue Func

[jira] [Created] (FLINK-18441) support Local-Global Aggregation with LastValue Funciton

wangpeibin created FLINK-18441: -- Summary: support Local-Global Aggregation with LastValue Funciton Key: FLINK-18441 URL: https://issues.apache.org/jira/browse/FLINK-18441 Project: Flink Issue T

[jira] [Created] (FLINK-13008) fix the findbugs warning in AggregationsFunction

wangpeibin created FLINK-13008: -- Summary: fix the findbugs warning in AggregationsFunction Key: FLINK-13008 URL: https://issues.apache.org/jira/browse/FLINK-13008 Project: Flink Issue Type: Impr

[jira] [Closed] (FLINK-11510) Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

[ https://issues.apache.org/jira/browse/FLINK-11510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin closed FLINK-11510. -- Resolution: Won't Do > Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] > positionToS

[jira] [Updated] (FLINK-11706) Add the SumFunction to support KeyedStream.sum with field which is array

[ https://issues.apache.org/jira/browse/FLINK-11706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin updated FLINK-11706: --- Description: The goal is to implement a KeyedStream API to sum with *the field which is array*. Th

[jira] [Created] (FLINK-11706) Add the SumFunction to support KeyedStream.sum with field which is array

wangpeibin created FLINK-11706: -- Summary: Add the SumFunction to support KeyedStream.sum with field which is array Key: FLINK-11706 URL: https://issues.apache.org/jira/browse/FLINK-11706 Project: Flink

[jira] [Commented] (FLINK-11510) Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

[ https://issues.apache.org/jira/browse/FLINK-11510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771088#comment-16771088 ] wangpeibin commented on FLINK-11510: [~aljoscha] could you review this pr  [GitHub P

[jira] [Assigned] (FLINK-11510) Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

[ https://issues.apache.org/jira/browse/FLINK-11510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangpeibin reassigned FLINK-11510: -- Assignee: wangpeibin > Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] > po

[jira] [Created] (FLINK-11510) Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

wangpeibin created FLINK-11510: -- Summary: Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums ) Key: FLINK-11510 URL: https://issues.apache.org/jira/browse/FLINK-11510 Project