[jira] [Commented] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712937#comment-17712937 ] Krzysztof Chmielewski commented on FLINK-31811: --- Hi [~jirawech.s] ??Could you share me

[jira] [Comment Edited] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712410#comment-17712410 ] Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:18 PM:

[jira] [Comment Edited] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390 ] Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:18 PM:

[jira] [Comment Edited] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712410#comment-17712410 ] Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:17 PM:

[jira] [Commented] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712410#comment-17712410 ] Krzysztof Chmielewski commented on FLINK-31811: --- [~jirawech.s] I've pasted a wrong ticket

[jira] [Comment Edited] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390 ] Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:16 PM:

[jira] [Comment Edited] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390 ] Krzysztof Chmielewski edited comment on FLINK-31811 at 4/14/23 2:15 PM:

[jira] [Commented] (FLINK-31811) Unsupported complex data type for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-31811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712390#comment-17712390 ] Krzysztof Chmielewski commented on FLINK-31811: --- I think this might be a duplicate of

[jira] [Comment Edited] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700264#comment-17700264 ] Krzysztof Chmielewski edited comment on FLINK-26051 at 4/4/23 11:00 AM:

[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700264#comment-17700264 ] Krzysztof Chmielewski commented on FLINK-26051: --- hi [~qingyue] I wonder, isn't the issue

[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699685#comment-17699685 ] Krzysztof Chmielewski commented on FLINK-26051: --- Hi [~qingyue] I would like to help with

[jira] [Updated] (FLINK-31202) Add support for reading Parquet files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31202: -- Attachment: ParquetSourceArrayOfArraysIssue.java

[jira] [Updated] (FLINK-31202) Add support for reading Parquet files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31202: -- Attachment: arrayOfArrayOfInts.snappy.parquet

[jira] [Updated] (FLINK-31202) Add support for reading Parquet files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31202: -- Description: reading complex types to Parquet is possible since Flink 1.16

[jira] [Created] (FLINK-31202) Add support for reading Parquet files containing Arrays with complex types.

Krzysztof Chmielewski created FLINK-31202: - Summary: Add support for reading Parquet files containing Arrays with complex types. Key: FLINK-31202 URL: https://issues.apache.org/jira/browse/FLINK-31202

[jira] [Updated] (FLINK-31197) Unable to write Parquet files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31197: -- Summary: Unable to write Parquet files containing Arrays with complex types.

[jira] [Updated] (FLINK-31197) Exception while writing Parqeut files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31197: -- Component/s: Connectors / FileSystem Formats (JSON, Avro,

[jira] [Updated] (FLINK-31197) Exception while writing Parqeut files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31197: -- Description: After https://issues.apache.org/jira/browse/FLINK-17782 It

[jira] [Updated] (FLINK-31197) Exception while writing Parqeut files containing Arrays with complex types.

[ https://issues.apache.org/jira/browse/FLINK-31197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-31197: -- Description: After https://issues.apache.org/jira/browse/FLINK-17782 It

[jira] [Created] (FLINK-31197) Exception while writing Parqeut files containing Arrays with complex types.

Krzysztof Chmielewski created FLINK-31197: - Summary: Exception while writing Parqeut files containing Arrays with complex types. Key: FLINK-31197 URL: https://issues.apache.org/jira/browse/FLINK-31197

[jira] [Comment Edited] (FLINK-31021) JavaCodeSplitter doesn't split static method properly

[ https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687449#comment-17687449 ] Krzysztof Chmielewski edited comment on FLINK-31021 at 2/11/23 2:10 PM:

[jira] [Commented] (FLINK-31021) JavaCodeSplitter doesn't split static method properly

[ https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687449#comment-17687449 ] Krzysztof Chmielewski commented on FLINK-31021: --- Ok so I verified and it seems that this

[jira] [Commented] (FLINK-31021) JavaCodeSplitter doesn't split static method properly

[ https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687368#comment-17687368 ] Krzysztof Chmielewski commented on FLINK-31021: --- Hi, i have few questions. 1. Could you

[jira] [Comment Edited] (FLINK-31018) SQL Client -j option does not load user jars to classpath.

[ https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687218#comment-17687218 ] Krzysztof Chmielewski edited comment on FLINK-31018 at 2/10/23 5:39 PM:

[jira] [Closed] (FLINK-31018) SQL Client -j option does not load user jars to classpath.

[ https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski closed FLINK-31018. - Resolution: Not A Bug > SQL Client -j option does not load user jars to

[jira] [Commented] (FLINK-31018) SQL Client -j option does not load user jars to classpath.

[ https://issues.apache.org/jira/browse/FLINK-31018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687218#comment-17687218 ] Krzysztof Chmielewski commented on FLINK-31018: --- [~martijnvisser] yes it seemt that this

[jira] [Created] (FLINK-31018) SQL Client -j option does not load user jars to classpath.

Krzysztof Chmielewski created FLINK-31018: - Summary: SQL Client -j option does not load user jars to classpath. Key: FLINK-31018 URL: https://issues.apache.org/jira/browse/FLINK-31018 Project:

[jira] [Commented] (FLINK-23016) Job client must be a Coordination Request Gateway when submit a job on web ui

[ https://issues.apache.org/jira/browse/FLINK-23016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687090#comment-17687090 ] Krzysztof Chmielewski commented on FLINK-23016: --- FYI, got the same error on Flink 1.16.1

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 2/7/23 11:20 AM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 2/7/23 11:19 AM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 2/7/23 11:15 AM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 2/7/23 11:12 AM:

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685220#comment-17685220 ] Krzysztof Chmielewski commented on FLINK-30927: --- master:

[jira] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927 ] Krzysztof Chmielewski deleted comment on FLINK-30927: --- was (Author: kristoffsc): master: 96a296db723575d64857482a1278744e4c41201f > Several tests started generate output with two

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685215#comment-17685215 ] Krzysztof Chmielewski commented on FLINK-30927: --- master:

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685175#comment-17685175 ] Krzysztof Chmielewski commented on FLINK-30927: --- PR needs to be merged to 1.17 branch

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684943#comment-17684943 ] Krzysztof Chmielewski commented on FLINK-30927: --- OK, CI build is green for provided PR,

[jira] [Comment Edited] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684726#comment-17684726 ] Krzysztof Chmielewski edited comment on FLINK-30927 at 2/6/23 4:31 PM:

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684726#comment-17684726 ] Krzysztof Chmielewski commented on FLINK-30927: --- Provided PR above is fixing reported

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684706#comment-17684706 ] Krzysztof Chmielewski commented on FLINK-30927: --- Pull request available

[jira] [Commented] (FLINK-30927) Several tests started generate output with two non-abstract methods have the same parameter types, declaring type and return type

[ https://issues.apache.org/jira/browse/FLINK-30927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684687#comment-17684687 ] Krzysztof Chmielewski commented on FLINK-30927: --- I already have fix for this, will provide

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 2/6/23 8:48 AM:

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski commented on FLINK-27246: --- master merge commit:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684496#comment-17684496 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 2/6/23 8:12 AM:

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655573#comment-17655573 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper], [~twalthr] and [~jingge]

[jira] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246 ] Krzysztof Chmielewski deleted comment on FLINK-27246: --- was (Author: kristoffsc): Hi [~TsReaper], [~twalthr] and [~jingge] I have finally finished working on my PR for this issue.

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655572#comment-17655572 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 1/6/23 8:16 PM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655572#comment-17655572 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 1/6/23 8:12 PM:

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655572#comment-17655572 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] I have finally finished

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653156#comment-17653156 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] I have modified my PR. I

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652279#comment-17652279 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] Thanks for the feedback.

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642072#comment-17642072 ] Krzysztof Chmielewski commented on FLINK-27246: --- [~TsReaper] I would love for your

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642072#comment-17642072 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 12/1/22 5:42 PM:

[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640037#comment-17640037 ] Krzysztof Chmielewski commented on FLINK-26051: --- Hi :) [~qingyue] Do you have any update

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 7:21 PM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 7:20 PM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:23 AM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:23 AM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:14 AM:

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] Im sory for a long delay.

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277 ] Krzysztof Chmielewski edited comment on FLINK-25920 at 11/9/22 8:41 PM:

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277 ] Krzysztof Chmielewski edited comment on FLINK-25920 at 11/9/22 8:41 PM:

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277 ] Krzysztof Chmielewski edited comment on FLINK-25920 at 11/9/22 8:40 PM:

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631277#comment-17631277 ] Krzysztof Chmielewski commented on FLINK-25920: --- [~bdine] could you share what kind of

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628218#comment-17628218 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/3/22 9:31 AM:

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628218#comment-17628218 ] Krzysztof Chmielewski commented on FLINK-27246: --- [~TsReaper] I see why my comment was

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627602#comment-17627602 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] Thanks for replaying. The

[jira] [Updated] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-27246: -- Attachment: endInput_falseFilter9123_split9704.txt > Code of method >

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625871#comment-17625871 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 10/29/22 8:24 AM:

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625871#comment-17625871 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi, I would like to try fix this problem

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621187#comment-17621187 ] Krzysztof Chmielewski commented on FLINK-29459: --- FYI ticets 29509 29512 29627 are fixing

[jira] [Comment Edited] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616307#comment-17616307 ] Krzysztof Chmielewski edited comment on FLINK-29589 at 10/20/22 9:10 AM:

[jira] [Commented] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620355#comment-17620355 ] Krzysztof Chmielewski commented on FLINK-29627: --- Backports: 1.15 -

[jira] [Commented] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619570#comment-17619570 ] Krzysztof Chmielewski commented on FLINK-29627: --- New PR without SinkItTest

[jira] [Comment Edited] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617611#comment-17617611 ] Krzysztof Chmielewski edited comment on FLINK-29627 at 10/14/22 9:54 AM:

[jira] [Comment Edited] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617611#comment-17617611 ] Krzysztof Chmielewski edited comment on FLINK-29627 at 10/14/22 9:54 AM:

[jira] [Comment Edited] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617611#comment-17617611 ] Krzysztof Chmielewski edited comment on FLINK-29627 at 10/14/22 9:54 AM:

[jira] [Comment Edited] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617611#comment-17617611 ] Krzysztof Chmielewski edited comment on FLINK-29627 at 10/14/22 9:53 AM:

[jira] [Commented] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17617611#comment-17617611 ] Krzysztof Chmielewski commented on FLINK-29627: --- PR

[jira] [Updated] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29627: -- Description: Recovery more than one Committable causes

[jira] [Updated] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29627: -- Description: Recovery more than one Committable causes

[jira] [Commented] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616925#comment-17616925 ] Krzysztof Chmielewski commented on FLINK-29627: --- I have a fix and tests for this issue.

[jira] [Created] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

Krzysztof Chmielewski created FLINK-29627: - Summary: Sink - Duplicate key exception during recover more than 1 committable. Key: FLINK-29627 URL: https://issues.apache.org/jira/browse/FLINK-29627

[jira] [Commented] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616307#comment-17616307 ] Krzysztof Chmielewski commented on FLINK-29589: --- Hi [~chesnay] V2 on 1.15, 1.16 and 1.17

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink architecture with global committer seems to be

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink architecture with global committer seems to be

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink architecture with global committer seems to be

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink architecture with global committer seems to be

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink architecture with global committer seems to be

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink architecture with global committer seems to be

[jira] [Created] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

Krzysztof Chmielewski created FLINK-29589: - Summary: Data Loss in Sink GlobalCommitter during Task Manager recovery Key: FLINK-29589 URL: https://issues.apache.org/jira/browse/FLINK-29589

[jira] [Updated] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Chmielewski updated FLINK-29589: -- Description: Flink's Sink's architecture with global committer seems to be

[jira] [Comment Edited] (FLINK-29509) Set correct subtaskId during recovery of committables

[ https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613888#comment-17613888 ] Krzysztof Chmielewski edited comment on FLINK-29509 at 10/7/22 4:29 PM:

[jira] [Commented] (FLINK-29509) Set correct subtaskId during recovery of committables

[ https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613888#comment-17613888 ] Krzysztof Chmielewski commented on FLINK-29509: --- PR:

[jira] [Commented] (FLINK-29509) Set correct subtaskId during recovery of committables

[ https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613527#comment-17613527 ] Krzysztof Chmielewski commented on FLINK-29509: --- Hi, I would like to work on this thicket.

[jira] [Comment Edited] (FLINK-28591) Array> is not serialized correctly when BigInt is present

[ https://issues.apache.org/jira/browse/FLINK-28591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568488#comment-17568488 ] Krzysztof Chmielewski edited comment on FLINK-28591 at 7/19/22 11:51 AM:

[jira] [Commented] (FLINK-28591) Array> is not serialized correctly when BigInt is present

[ https://issues.apache.org/jira/browse/FLINK-28591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568488#comment-17568488 ] Krzysztof Chmielewski commented on FLINK-28591: --- The potential issue might be in