[jira] [Created] (FLINK-36779) topn.cache.size metric is incorrect and non-changing during the time

Roman Boyko created FLINK-36779: --- Summary: topn.cache.size metric is incorrect and non-changing during the time Key: FLINK-36779 URL: https://issues.apache.org/jira/browse/FLINK-36779 Project: Flink

[jira] [Created] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

Roman Boyko created FLINK-35184: --- Summary: Hash collision inside MiniBatchStreamingJoin operator Key: FLINK-35184 URL: https://issues.apache.org/jira/browse/FLINK-35184 Project: Flink Issue

Re: Support minibatch for TopNFunction

found in document [2] (under Nexmark subtitle) Looking forward to your feedback. [1] https://github.com/rovboyko/flink/tree/feature/topn-output-buffer [2] https://docs.google.com/document/d/1YPHwxKfiGSUOUOa6bc68fIJHO_UojTwZEC29VVEa-Uk -- Best regards, Roman Boyko e.: ro.v.bo...@gmail.com m

Re: Support minibatch for TopNFunction

9VVEa-Uk <https://docs.google.com/document/d/1YPHwxKfiGSUOUOa6bc68fIJHO_UojTwZEC29VVEa-Uk/edit?usp=sharing> -- Best regards, Roman Boyko e.: ro.v.bo...@gmail.com m.: +79059592443 telegram: @rboyko On Thu, 28 Mar 2024 at 09:41, shuai xu wrote: > Hi, Roman > > Thanks for your proposal. I think t

Re: Support minibatch for TopNFunction

ptimization applies to? > 3. Is it possible to provide the PoC code? > 4. finally, we need a formal FLIP document on the wiki[2]. > > [1] > > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/tuning/#minibatch-regular-joins > [2] > > https://cwiki.apache.org

Re: Support minibatch for TopNFunction

Hi Flink Community, I tried to describe my idea about minibatch for TopNFunction in this doc - https://docs.google.com/document/d/1YPHwxKfiGSUOUOa6bc68fIJHO_UojTwZEC29VVEa-Uk/edit?usp=sharing Looking forward to your feedback, thank you On Tue, 19 Mar 2024 at 12:24, Roman Boyko wrote: > He

Support minibatch for TopNFunction

] https://cwiki.apache.org/confluence/display/FLINK/FLIP-415 %3A+Introduce+a+new+join+operator+to+support+minibatch -- Best regards, Roman Boyko e.: ro.v.bo...@gmail.com m.: +79059592443 telegram: @rboyko

[jira] [Created] (FLINK-34694) Delete num of associations for streaming outer join

Roman Boyko created FLINK-34694: --- Summary: Delete num of associations for streaming outer join Key: FLINK-34694 URL: https://issues.apache.org/jira/browse/FLINK-34694 Project: Flink Issue Type

[jira] [Created] (FLINK-30088) Excessive state updates for TtlMapState and TtlListState

Roman Boyko created FLINK-30088: --- Summary: Excessive state updates for TtlMapState and TtlListState Key: FLINK-30088 URL: https://issues.apache.org/jira/browse/FLINK-30088 Project: Flink Issue

FLIP-50 current status

this feature unfinished? Thank you in advance! [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-50%3A+Spill-able+Heap+Keyed+State+Backend [2] https://github.com/realtime-storage-engine/flink-spillable-statebackend -- Best regards, Roman Boyko e.: ro.v.bo...@gmail.com m.: +79059592443

Re: [DISCUSS] FLIP-224: Blacklist Mechanism

hink the semantics of > > >> >

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

; caching and metrics. > > Best regards, > > Martijn Visser > https://twitter.com/MartijnVisser82 > https://github.com/MartijnVisser > > > On Thu, 5 May 2022 at 13:58, Roman Boyko wrote: > > > Hi everyone! > > > > Thanks for driving such a va

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

to the schema proposed by Alexander. Qingshen Ren, please correct me if I'm not right and all these facilities might be simply implemented in your architecture? Best regards, Roman Boyko e.: ro.v.bo...@gmail.com On Wed, 4 May 2022 at 21:01, Martijn Visser wrote: > Hi everyone, > >