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

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842232#comment-17842232 ] Roman Boyko commented on FLINK-35184: - [~lsy] , done - https://github.com/apache/fli

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842243#comment-17842243 ] Roman Boyko commented on FLINK-34380: - [~xuyangzhong] , [~xu_shuai_] , what do you t

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846140#comment-17846140 ] Roman Boyko commented on FLINK-34694: - [~xu_shuai_] , please take a look. > Delete

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846141#comment-17846141 ] Roman Boyko commented on FLINK-34380: - [~xu_shuai_] , [~xuyangzhong] , could you ple

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846516#comment-17846516 ] Roman Boyko commented on FLINK-34380: - Hi [~xuyangzhong] ! Thank you for your reply.

[jira] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380 ] Roman Boyko deleted comment on FLINK-34380: - was (Author: rovboyko): Hi [~xuyangzhong] ! Thank you for your reply. > Strange RowKind and records about intermediate output when using minibatc

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846520#comment-17846520 ] Roman Boyko commented on FLINK-34380: - Hi [~xuyangzhong] ! Thank you for your reply.

[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846520#comment-17846520 ] Roman Boyko edited comment on FLINK-34380 at 5/15/24 7:14 AM:

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846895#comment-17846895 ] Roman Boyko commented on FLINK-34380: - Hi [~xu_shuai_] ! I can't agree with you bec

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848532#comment-17848532 ] Roman Boyko commented on FLINK-34694: - Hi [~xu_shuai_] ! Could you please take a lo

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849151#comment-17849151 ] Roman Boyko commented on FLINK-34380: - Hi [~xu_shuai_] , [~xuyangzhong] ! I still t

[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849151#comment-17849151 ] Roman Boyko edited comment on FLINK-34380 at 5/24/24 4:17 AM:

[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849151#comment-17849151 ] Roman Boyko edited comment on FLINK-34380 at 5/24/24 4:18 AM:

[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] [Commented] (FLINK-34694) Delete num of associations for streaming outer join

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827664#comment-17827664 ] Roman Boyko commented on FLINK-34694: - After failed CI I've realized the state is ch

[jira] [Commented] (FLINK-30535) Introduce TTL state based benchmarks

[ https://issues.apache.org/jira/browse/FLINK-30535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828309#comment-17828309 ] Roman Boyko commented on FLINK-30535: - [~Zakelly] , thank for this functionality! O

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829770#comment-17829770 ] Roman Boyko commented on FLINK-34694: - [~libenchao] What do you think about feature

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Boyko updated FLINK-34694: Affects Version/s: (was: 1.16.3) (was: 1.17.2)

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

[ https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Boyko updated FLINK-30088: Labels: pull-request-available (was: pull-request-available stale-assigned) > Excessive state upd

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

[ https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832804#comment-17832804 ] Roman Boyko commented on FLINK-30088: - I've updated the PR ([https://github.com/apac

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835599#comment-17835599 ] Roman Boyko commented on FLINK-34694: - [~martijnvisser] , could you please help with

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835650#comment-17835650 ] Roman Boyko commented on FLINK-34694: - Hi [~xu_shuai_] ! Thank you for your reply!

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Boyko updated FLINK-34694: Attachment: image-2024-04-15-15-45-51-027.png > Delete num of associations for streaming outer joi

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Boyko updated FLINK-34694: Attachment: image-2024-04-15-15-46-17-671.png > Delete num of associations for streaming outer joi

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205 ] Roman Boyko commented on FLINK-34694: - Hi [~xu_shuai_] ! I prepared and executed al

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

[ https://issues.apache.org/jira/browse/FLINK-34694 ] Roman Boyko deleted comment on FLINK-34694: - was (Author: rovboyko): The images of profiler results for previous comment. BEFOR optimization: !image-2024-04-15-19-05-50-379.png!   AFTER o

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837211#comment-17837211 ] Roman Boyko commented on FLINK-34694: - The images of profiler results for previous c

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Boyko updated FLINK-34694: Attachment: image-2024-04-15-19-14-14-735.png > Delete num of associations for streaming outer joi

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205 ] Roman Boyko edited comment on FLINK-34694 at 4/15/24 12:15 PM: ---

[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 Typ

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

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839382#comment-17839382 ] Roman Boyko commented on FLINK-35184: - please assign this bug on me, I'm working on

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839474#comment-17839474 ] Roman Boyko commented on FLINK-34380: - Hi [~xuyangzhong] , [~xu_shuai_] ! 1) The Ro

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

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839540#comment-17839540 ] Roman Boyko commented on FLINK-35184: - Most probably the easiest way to fix it would

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

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839578#comment-17839578 ] Roman Boyko commented on FLINK-35184: - "bug which is caused by the hashcode() in Gen

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

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839928#comment-17839928 ] Roman Boyko commented on FLINK-35184: - [~xu_shuai_] , Ok agree with you. So may I st

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

[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839978#comment-17839978 ] Roman Boyko commented on FLINK-35184: - I've found even simplier solution without cha

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205 ] Roman Boyko edited comment on FLINK-34694 at 4/26/24 10:01 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205 ] Roman Boyko edited comment on FLINK-34694 at 4/26/24 10:05 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837205#comment-17837205 ] Roman Boyko edited comment on FLINK-34694 at 4/26/24 10:04 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841427#comment-17841427 ] Roman Boyko commented on FLINK-34694: - Hi [~xu_shuai_] ! Could you please take a lo

[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

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

[ https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635875#comment-17635875 ] Roman Boyko commented on FLINK-30088: - The fix is ready - [https://github.com/rovbo

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564339#comment-17564339 ] Roman Boyko commented on FLINK-27438: - Hi [~twalthr] ! Could you please check the c

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531615#comment-17531615 ] Roman Boyko commented on FLINK-27438: - This bug appears at sql array construct time.

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532054#comment-17532054 ] Roman Boyko commented on FLINK-27438: - I've created a PR to master. [~martijnvisser]

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532758#comment-17532758 ] Roman Boyko commented on FLINK-27438: - [~martijnvisser] , could you please review th

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533252#comment-17533252 ] Roman Boyko commented on FLINK-27438: - master - 6b1cdf3b7c3bf2d8beb399f95d0a27733d6a

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17536414#comment-17536414 ] Roman Boyko commented on FLINK-27438: - Hi everyone! I've changed the solution accor

[jira] [Commented] (FLINK-27418) Flink SQL TopN result is wrong

[ https://issues.apache.org/jira/browse/FLINK-27418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539968#comment-17539968 ] Roman Boyko commented on FLINK-27418: - The bug exists indeed. The simplest way to re

[jira] [Comment Edited] (FLINK-27418) Flink SQL TopN result is wrong

[ https://issues.apache.org/jira/browse/FLINK-27418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539968#comment-17539968 ] Roman Boyko edited comment on FLINK-27418 at 5/20/22 7:40 AM:

[jira] [Commented] (FLINK-27418) Flink SQL TopN result is wrong

[ https://issues.apache.org/jira/browse/FLINK-27418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540342#comment-17540342 ] Roman Boyko commented on FLINK-27418: - The PR is ready - [https://github.com/apache/