[jira] [Created] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage

2025-07-10 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-38078: - Summary: DataStream API Execution Configuration doc contains deleted API usage Key: FLINK-38078 URL: https://issues.apache.org/jira/browse/FLINK-38078 Project: Flin

[jira] [Commented] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink

2025-06-16 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979352#comment-17979352 ] Zhanghao Chen commented on FLINK-34037: --- [~zjureel] All subtasks done, let's mark

[jira] [Commented] (FLINK-30513) HA storage dir leaks on cluster termination

2025-04-29 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948135#comment-17948135 ] Zhanghao Chen commented on FLINK-30513: --- [~xinchen147] We imlemented this feature

[jira] [Updated] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs

2025-04-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37722: -- Description: Currently, PojoSerializer will first create a new POJO instance and initialize a

[jira] [Updated] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs

2025-04-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37722: -- Attachment: image-2025-04-27-14-40-25-539.png > Eliminate redundant field initialization when

[jira] [Updated] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs

2025-04-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37722: -- Description: Currently, PojoSerializer will first create a new POJO instance and initialize a

[jira] [Updated] (FLINK-37735) Replace class.newInstance with constructor.newInstance

2025-04-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37735: -- Description: *Problem* Flink's PojoSerializer and TupleSerializer uses {{class.newInstance}}

[jira] [Commented] (FLINK-37735) Replace class.newInstance with constructor.newInstance

2025-04-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947578#comment-17947578 ] Zhanghao Chen commented on FLINK-37735: --- Side note: we also tested with {{{}Lambda

[jira] [Created] (FLINK-37735) Replace class.newInstance with constructor.newInstance

2025-04-26 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37735: - Summary: Replace class.newInstance with constructor.newInstance Key: FLINK-37735 URL: https://issues.apache.org/jira/browse/FLINK-37735 Project: Flink Issu

[jira] [Created] (FLINK-37722) Eliminate redundant field initialization when deserializing POJOs

2025-04-24 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37722: - Summary: Eliminate redundant field initialization when deserializing POJOs Key: FLINK-37722 URL: https://issues.apache.org/jira/browse/FLINK-37722 Project: Flink

[jira] [Commented] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc

2025-04-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946128#comment-17946128 ] Zhanghao Chen commented on FLINK-37226: --- [~leejeonghwan] Sure, go ahead > Replace

[jira] [Created] (FLINK-37680) Add subclass cache for PojoSerializer

2025-04-15 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37680: - Summary: Add subclass cache for PojoSerializer Key: FLINK-37680 URL: https://issues.apache.org/jira/browse/FLINK-37680 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37681) Add benchmark for subclass seder with PojoSerializer in Flink benchmark

2025-04-15 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37681: - Summary: Add benchmark for subclass seder with PojoSerializer in Flink benchmark Key: FLINK-37681 URL: https://issues.apache.org/jira/browse/FLINK-37681 Project: Fl

[jira] [Updated] (FLINK-37680) Add subclass cache for PojoSerializer

2025-04-15 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37680: -- Attachment: (was: image-2025-04-15-16-31-21-369.png) > Add subclass cache for PojoSerializ

[jira] [Created] (FLINK-37679) Improve the performance of Flink serialization

2025-04-15 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37679: - Summary: Improve the performance of Flink serialization Key: FLINK-37679 URL: https://issues.apache.org/jira/browse/FLINK-37679 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-13 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943995#comment-17943995 ] Zhanghao Chen edited comment on FLINK-37659 at 4/14/25 1:25 AM: --

[jira] [Commented] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-13 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943995#comment-17943995 ] Zhanghao Chen commented on FLINK-37659: --- Hi [~Weijie Guo], could help review it?

[jira] [Created] (FLINK-37661) Remove Kryo serializer reference data from version 1.x

2025-04-11 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37661: - Summary: Remove Kryo serializer reference data from version 1.x Key: FLINK-37661 URL: https://issues.apache.org/jira/browse/FLINK-37661 Project: Flink Issu

[jira] [Created] (FLINK-37660) Reenable Kryo serializer upgrade tests

2025-04-11 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37660: - Summary: Reenable Kryo serializer upgrade tests Key: FLINK-37660 URL: https://issues.apache.org/jira/browse/FLINK-37660 Project: Flink Issue Type: Technica

[jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37659: -- Parent: (was: FLINK-35952) Issue Type: Improvement (was: Sub-task) > Flink 2.0: u

[jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37659: -- Affects Version/s: 2.0.0 > Flink 2.0: update reference data for Migration Tests >

[jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37659: -- Fix Version/s: 2.1.0 (was: 2.0-preview) > Flink 2.0: update reference d

[jira] [Updated] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37659: -- Labels: (was: pull-request-available) > Flink 2.0: update reference data for Migration Tests

[jira] [Created] (FLINK-37659) Flink 2.0: update reference data for Migration Tests

2025-04-11 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37659: - Summary: Flink 2.0: update reference data for Migration Tests Key: FLINK-37659 URL: https://issues.apache.org/jira/browse/FLINK-37659 Project: Flink Issue

[jira] [Commented] (FLINK-35145) Add timeout for cluster termination

2025-03-05 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932569#comment-17932569 ] Zhanghao Chen commented on FLINK-35145: --- [~nishita0905] Hi, what you described sou

[jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0

2025-02-25 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930530#comment-17930530 ] Zhanghao Chen commented on FLINK-37248: --- [~911432] You can find links to externali

[jira] [Commented] (FLINK-37248) Scala was removed in flink 2.0

2025-02-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926265#comment-17926265 ] Zhanghao Chen commented on FLINK-37248: --- [~911432] These connectors are externaliz

[jira] [Commented] (FLINK-37047) Cross-team verification for "Remove DataSet API"

2025-02-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926264#comment-17926264 ] Zhanghao Chen commented on FLINK-37047: --- [~yyhx] Thanks for the clarification, LGT

[jira] [Commented] (FLINK-37060) Cross-team verification for FLIP-398

2025-02-03 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923607#comment-17923607 ] Zhanghao Chen commented on FLINK-37060: --- [~xtsong] I've finished the instruction,

[jira] [Commented] (FLINK-37049) Cross-team verification for "Remove all Scala APIs"

2025-02-03 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923605#comment-17923605 ] Zhanghao Chen commented on FLINK-37049: --- In addition, FLINK-37248 reported that so

[jira] [Created] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util

2025-02-03 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37249: - Summary: Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util Key: FLINK-37249 URL: https://issues.apache.org/jira/browse/FLINK-37249 Project: Fl

[jira] [Commented] (FLINK-37060) Cross-team verification for FLIP-398

2025-01-30 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922605#comment-17922605 ] Zhanghao Chen commented on FLINK-37060: --- In Flink 2.0, we introduced built-in dedi

[jira] [Commented] (FLINK-37225) Remove remaining test resources of Gelly

2025-01-25 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917021#comment-17917021 ] Zhanghao Chen commented on FLINK-37225: --- [~martijnvisser] Could you help take a lo

[jira] [Created] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc

2025-01-25 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37226: - Summary: Replace deprecated methods in the DataStream API introduction doc Key: FLINK-37226 URL: https://issues.apache.org/jira/browse/FLINK-37226 Project: Flink

[jira] [Commented] (FLINK-37047) Cross-team verification for "Remove DataSet API"

2025-01-25 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917007#comment-17917007 ] Zhanghao Chen commented on FLINK-37047: --- Hi [~yyhx], I've noticed two potential is

[jira] [Commented] (FLINK-37049) Cross-team verification for "Remove all Scala APIs"

2025-01-25 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17917005#comment-17917005 ] Zhanghao Chen commented on FLINK-37049: --- [~yyhx] I confirmed that the DS Scala API

[jira] [Updated] (FLINK-37225) Remove remaining test resources of Gelly

2025-01-25 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37225: -- Description: Some test resources of Gelly remained after FLINK-29668. !image-2025-01-26-09-34

[jira] [Created] (FLINK-37225) Remove remaining test resources of Gelly

2025-01-25 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37225: - Summary: Remove remaining test resources of Gelly Key: FLINK-37225 URL: https://issues.apache.org/jira/browse/FLINK-37225 Project: Flink Issue Type: Techni

[jira] [Created] (FLINK-37101) Remove internal set methods in SerializerConfig

2025-01-11 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37101: - Summary: Remove internal set methods in SerializerConfig Key: FLINK-37101 URL: https://issues.apache.org/jira/browse/FLINK-37101 Project: Flink Issue Type:

[jira] [Updated] (FLINK-37024) Task can be stuck in deploying state forever when canceling job/failover

2025-01-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-37024: -- Description: We observed that task can be stuck in deploying state forever when the task loadi

[jira] [Created] (FLINK-37024) Task can be stuck in deploying state forever when canceling job/failover

2025-01-07 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37024: - Summary: Task can be stuck in deploying state forever when canceling job/failover Key: FLINK-37024 URL: https://issues.apache.org/jira/browse/FLINK-37024 Project: F

[jira] [Created] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly

2025-01-06 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-37015: - Summary: Revise serialization doc to reflect the 2.0 breaking changes properly Key: FLINK-37015 URL: https://issues.apache.org/jira/browse/FLINK-37015 Project: Flin

[jira] [Closed] (FLINK-36903) Flink 2.0: Add switch for built-in serialization support for common collection types

2025-01-06 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen closed FLINK-36903. - Resolution: Workaround > Flink 2.0: Add switch for built-in serialization support for common >

[jira] [Commented] (FLINK-36903) Flink 2.0: Add switch for built-in serialization support for common collection types

2025-01-06 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910074#comment-17910074 ] Zhanghao Chen commented on FLINK-36903: --- Adding a switch turned out to be difficul

[jira] [Commented] (FLINK-35555) Serializing List with null values throws NPE

2025-01-06 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910071#comment-17910071 ] Zhanghao Chen commented on FLINK-3: --- It turned out that there're more issues w

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

2025-01-05 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910011#comment-17910011 ] Zhanghao Chen commented on FLINK-33265: --- [~yunta] [~lincoln.86xy] RocMarshal has a

[jira] [Commented] (FLINK-22091) env.java.home option didn't take effect in resource negotiator

2024-12-31 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909042#comment-17909042 ] Zhanghao Chen commented on FLINK-22091: --- I tested it on both YARN & K8s. The confi

[jira] [Commented] (FLINK-22091) env.java.home option didn't take effect in resource negotiator

2024-12-31 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909041#comment-17909041 ] Zhanghao Chen commented on FLINK-22091: --- [~samrat007] Hi, is there any progress up

[jira] [Created] (FLINK-36905) Update Chinese document to reflect the changes of FLIP-398

2024-12-15 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-36905: - Summary: Update Chinese document to reflect the changes of FLIP-398 Key: FLINK-36905 URL: https://issues.apache.org/jira/browse/FLINK-36905 Project: Flink

[jira] [Resolved] (FLINK-36904) Fix document error on how to programmatically configure serialization

2024-12-15 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen resolved FLINK-36904. --- Fix Version/s: 2.0.0 Resolution: Fixed Resolved via d541997954e7b28ffa9df5e4bcaea817c

[jira] (FLINK-35555) Serializing List with null values throws NPE

2024-12-15 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3 ] Zhanghao Chen deleted comment on FLINK-3: --- was (Author: zhanghao chen): FLINK-23420 is similar to our case here. We can extend ListSerializer to allow null values via  a binary mask fo

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

2024-12-15 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-3: -- Description: FLINK-34123 introduced built-in serialization support for java.util.List, which

[jira] [Updated] (FLINK-36904) Fix document error on how to programmatically configure serialization

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-36904: -- Summary: Fix document error on how to programmatically configure serialization (was: Fix doc

[jira] [Updated] (FLINK-36904) Fix doc error on how to programmatically register a 3rd-party serializer

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-36904: -- Description: >From user email: >https://lists.apache.org/thread/mdokv42k0zxlxdwl7y61hv2pc3fjw

[jira] [Created] (FLINK-36904) Fix doc error on how to programmatically register a 3rd-party serializer

2024-12-14 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-36904: - Summary: Fix doc error on how to programmatically register a 3rd-party serializer Key: FLINK-36904 URL: https://issues.apache.org/jira/browse/FLINK-36904 Project: F

[jira] [Updated] (FLINK-36903) Flink 2.0: Add switch for built-in serialization support for common collection types

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-36903: -- Summary: Flink 2.0: Add switch for built-in serialization support for common collection types

[jira] [Updated] (FLINK-35458) Flink 2.0: Add serializer upgrade test for set serializer

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35458: -- Fix Version/s: (was: 2.0.0) > Flink 2.0: Add serializer upgrade test for set serializer >

[jira] [Updated] (FLINK-35458) Flink 2.1: Add serializer upgrade test for set serializer

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35458: -- Summary: Flink 2.1: Add serializer upgrade test for set serializer (was: Flink 2.0: Add seria

[jira] [Updated] (FLINK-35458) Flink 2.0: Add serializer upgrade test for set serializer

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35458: -- Affects Version/s: 2.0.0 (was: 1.20.0) > Flink 2.0: Add serializer

[jira] [Created] (FLINK-36903) Add switch for built-in serialization support for common collection types

2024-12-14 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-36903: - Summary: Add switch for built-in serialization support for common collection types Key: FLINK-36903 URL: https://issues.apache.org/jira/browse/FLINK-36903 Project:

[jira] [Updated] (FLINK-35458) Flink 2.0: Add serializer upgrade test for set serializer

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35458: -- Description: New dedicated serializer for Sets is introduced in FLINK-35068. Since serializer

[jira] [Reopened] (FLINK-35068) Introduce built-in serialization support for Set

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen reopened FLINK-35068: --- Reopen it as reverted in 894feed5f3eb4fb38c53001a7cc8727d7fe46bb5. > Introduce built-in seriali

[jira] [Updated] (FLINK-35068) Introduce built-in serialization support for Set

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35068: -- Fix Version/s: 2.0.0 (was: 1.20.0) > Introduce built-in serialization s

[jira] [Updated] (FLINK-34123) Introduce built-in serialization support for Map and List

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34123: -- Fix Version/s: 2.0.0 (was: 1.20.0) > Introduce built-in serialization s

[jira] [Reopened] (FLINK-34123) Introduce built-in serialization support for Map and List

2024-12-14 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen reopened FLINK-34123: --- Reopen it as reverted in 894feed5f3eb4fb38c53001a7cc8727d7fe46bb5. > Introduce built-in seriali

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

2024-12-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904778#comment-17904778 ] Zhanghao Chen commented on FLINK-33265: --- [~lincoln.86xy] I've created a PR, would

[jira] [Commented] (FLINK-35817) High RSS Memory Growth in Long-Running Flink Tasks with Low Heap Usage: Is Prometheus Metrics Reporting the Culprit?

2024-07-28 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869170#comment-17869170 ] Zhanghao Chen commented on FLINK-35817: --- The screenshot indicates high usage of JV

[jira] [Commented] (FLINK-35903) Add CentralizedSlotAssigner support to adaptive scheduler

2024-07-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868873#comment-17868873 ] Zhanghao Chen commented on FLINK-35903: --- [~heigebupahei] Hi,[~RocMarshal] is alrea

[jira] [Commented] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

2024-07-24 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868519#comment-17868519 ] Zhanghao Chen commented on FLINK-33681: --- [~eric.xiao] Thanks for your attention! T

[jira] [Commented] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling

2024-07-23 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868038#comment-17868038 ] Zhanghao Chen commented on FLINK-33977: --- Hi [~RocMarshal], there's no progress on

[jira] [Commented] (FLINK-35068) Introduce built-in serialization support for Set

2024-06-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854247#comment-17854247 ] Zhanghao Chen commented on FLINK-35068: --- Will revert it as it breaks state-compati

[jira] [Commented] (FLINK-34123) Introduce built-in serialization support for Map and List

2024-06-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854242#comment-17854242 ] Zhanghao Chen commented on FLINK-34123: --- Will revert it as it breaks state-compati

[jira] [Updated] (FLINK-35068) Introduce built-in serialization support for Set

2024-06-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35068: -- Release Note: Dedicated serialization support for four common Java collection types: Map, List

[jira] [Updated] (FLINK-34123) Introduce built-in serialization support for Map and List

2024-06-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34123: -- Release Note: Dedicated serialization support for four common Java collection types: Map, List

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-3: -- Description: FLINK-34123 introduced built-in serialization support for java.util.List, which

[jira] [Comment Edited] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853132#comment-17853132 ] Zhanghao Chen edited comment on FLINK-3 at 6/7/24 12:38 PM: --

[jira] [Commented] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853132#comment-17853132 ] Zhanghao Chen commented on FLINK-3: --- FLINK-23420 is similar to our case here.

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-3: -- Priority: Critical (was: Major) > Serializing List with null values throws NPE >

[jira] [Commented] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853121#comment-17853121 ] Zhanghao Chen commented on FLINK-3: --- [~Weijie Guo] WDTY about the suggested fi

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-3: -- Description: FLINK-34123 introduced built-in serialization support for java.util.List, which

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-3: -- Description: FLINK-34123 introduced built-in serialization support for java.util.List, which

[jira] [Updated] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-3: -- Parent: FLINK-34037 Issue Type: Sub-task (was: Bug) > Serializing List with null valu

[jira] [Created] (FLINK-35555) Serializing List with null values throws NPE

2024-06-07 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-3: - Summary: Serializing List with null values throws NPE Key: FLINK-3 URL: https://issues.apache.org/jira/browse/FLINK-3 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

2024-06-05 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852443#comment-17852443 ] Zhanghao Chen commented on FLINK-33265: --- [~yunta] Hi, since it is dependant on the

[jira] [Commented] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

2024-05-28 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850219#comment-17850219 ] Zhanghao Chen commented on FLINK-33681: --- [~becket_qin] Thanks for the attention! I

[jira] [Commented] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-05-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849606#comment-17849606 ] Zhanghao Chen commented on FLINK-34239: --- [~mallikarjuna] Hi could you help rebase

[jira] [Created] (FLINK-35458) Add serializer upgrade test for set serializer

2024-05-26 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-35458: - Summary: Add serializer upgrade test for set serializer Key: FLINK-35458 URL: https://issues.apache.org/jira/browse/FLINK-35458 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35145: -- Description: Currently, cluster termination may be blocked forever as there's no timeout for

[jira] [Updated] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35145: -- Description: Currently, cluster termination may be blocked forever as there's no timeout for

[jira] [Commented] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838219#comment-17838219 ] Zhanghao Chen commented on FLINK-35145: --- [~fangyong] [~huweihua] WDYT about this?

[jira] [Created] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-35145: - Summary: Add timeout for cluster termination Key: FLINK-35145 URL: https://issues.apache.org/jira/browse/FLINK-35145 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-35068) Introduce built-in serialization support for Set

2024-04-09 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835353#comment-17835353 ] Zhanghao Chen commented on FLINK-35068: --- [~fangyong] May I take this task? > Intr

[jira] [Created] (FLINK-35068) Introduce built-in serialization support for Set

2024-04-09 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-35068: - Summary: Introduce built-in serialization support for Set Key: FLINK-35068 URL: https://issues.apache.org/jira/browse/FLINK-35068 Project: Flink Issue Type

[jira] [Updated] (FLINK-34123) Introduce built-in serialization support for Map and List

2024-04-09 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34123: -- Fix Version/s: 1.20.0 Affects Version/s: 1.20.0 (was: 1.19.0

[jira] [Commented] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-03-24 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830313#comment-17830313 ] Zhanghao Chen commented on FLINK-34239: --- [~mallikarjuna] Thanks for the PR, I'll t

[jira] [Comment Edited] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen edited comment on FLINK-25068 at 3/11/24 4:04 PM: --

[jira] [Commented] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen commented on FLINK-25068: --- Hi [~zlzhang0122][~lincoln.86xy], given t

[jira] [Commented] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-24 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820432#comment-17820432 ] Zhanghao Chen commented on FLINK-34354: --- [~Zakelly] Thanks for taking this! > Rel

[jira] [Updated] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: This issue aims to verify [FLIP-398|https://cwiki.apache.org/confluence/display/

[jira] [Updated] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: This issue aims to verify [FLIP-398|https://cwiki.apache.org/confluence/display/

  1   2   3   4   >