[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946477#comment-15946477 ]
shijinkui commented on FLINK-6204: ---------------------------------- -1. hi, guys. I want to know the differance between this PR and https://github.com/apache/flink/pull/3386 You have 138 comments, but now rewrite the FLINK-3386. Why not recommend this solution at 3386. Do we must waste of time on the same problem? > Improve Event-Time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL > --------------------------------------------------------------------------- > > Key: FLINK-6204 > URL: https://issues.apache.org/jira/browse/FLINK-6204 > Project: Flink > Issue Type: Bug > Components: Table API & SQL > Reporter: sunjincheng > Assignee: sunjincheng > > Currently `event time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to > SQL` implementation class: ` UnboundedEventTimeOverProcessFunction` use > data size uncontrollable memory data structures`sortedTimestamps: > util.LinkedList [Long] cache data timestamps and sort timestamps. IMO,It's > not a good way, because in the production environment there are millions of > window data pre millisecond in our application scenario.So, I want to remove > `util.LinkedList [Long] `. Welcome anyone to give me feedback. > What do you think? [~fhueske] and [~Yuhong_kyo] -- This message was sent by Atlassian JIRA (v6.3.15#6346)