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

[ 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-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825369#comment-17825369 ] Zhanghao Chen commented on FLINK-25068: --- Hi [~zlzhang0122][~lincoln.86xy], given that

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830313#comment-17830313 ] Zhanghao Chen commented on FLINK-34239: --- [~mallikarjuna] Thanks for the PR, I'll take a look >

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

[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835353#comment-17835353 ] Zhanghao Chen commented on FLINK-35068: --- [~fangyong] May I take this task? > Introduce built-in

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820432#comment-17820432 ] Zhanghao Chen commented on FLINK-34354: --- [~Zakelly] Thanks for taking this! > Release Testing:

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

[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849606#comment-17849606 ] Zhanghao Chen commented on FLINK-34239: --- [~mallikarjuna] Hi could you help rebase the code on the

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

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] [Created] (FLINK-35555) Serializing List with null values throws NPE

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:

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

[ 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

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

[ 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

[ 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] [Commented] (FLINK-35555) Serializing List with null values throws NPE

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853121#comment-17853121 ] Zhanghao Chen commented on FLINK-3: --- [~Weijie Guo] WDTY about the suggested fix? >

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853132#comment-17853132 ] Zhanghao Chen commented on FLINK-3: --- FLINK-23420 is similar to our case here. We can use a

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

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

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

[ 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] [Commented] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

[ https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850219#comment-17850219 ] Zhanghao Chen commented on FLINK-33681: --- [~becket_qin] Thanks for the attention! I've already

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

[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852443#comment-17852443 ] Zhanghao Chen commented on FLINK-33265: --- [~yunta] Hi, since it is dependant on the new API added

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854247#comment-17854247 ] Zhanghao Chen commented on FLINK-35068: --- Will revert it as it breaks state-compatibility. If a

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

[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854242#comment-17854242 ] Zhanghao Chen commented on FLINK-34123: --- Will revert it as it breaks state-compatibility. If a

<    1   2   3   4