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

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

[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&focusedCommentId=17854242#comment-17854242 ] Zhanghao Chen commented on FLINK-34123: --- Will revert it as it breaks state-compati

[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&focusedCommentId=17854247#comment-17854247 ] Zhanghao Chen commented on FLINK-35068: --- Will revert it as it breaks state-compati

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

[ 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-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&focusedCommentId=17868519#comment-17868519 ] Zhanghao Chen commented on FLINK-33681: --- [~eric.xiao] Thanks for your attention! T

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

[ 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-35817) High RSS Memory Growth in Long-Running Flink Tasks with Low Heap Usage: Is Prometheus Metrics Reporting the Culprit?

[ 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] [Updated] (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: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

[ 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

[ 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

[ 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] [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&focusedCommentId=17820432#comment-17820432 ] Zhanghao Chen commented on FLINK-34354: --- [~Zakelly] Thanks for taking this! > Rel

[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&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen commented on FLINK-25068: --- Hi [~zlzhang0122][~lincoln.86xy], given t

[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&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen edited comment on FLINK-25068 at 3/11/24 4:04 PM: --

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

[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-30513: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > HA storage dir

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

[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-30513: -- Affects Version/s: 1.17.0 1.18.0 > HA storage dir leaks on cluster term

[jira] [Commented] (FLINK-33262) Extend source provider interfaces with the new parallelism provider interface

[ https://issues.apache.org/jira/browse/FLINK-33262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781232#comment-17781232 ] Zhanghao Chen commented on FLINK-33262: --- [~libenchao] Could you assign the task to

[jira] [Commented] (FLINK-33264) Support source parallelism setting for DataGen connector

[ https://issues.apache.org/jira/browse/FLINK-33264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781233#comment-17781233 ] Zhanghao Chen commented on FLINK-33264: --- [~libenchao] Could you assign the task to

[jira] [Commented] (FLINK-33263) Implement ParallelismProvider for sources in Blink planner

[ https://issues.apache.org/jira/browse/FLINK-33263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786163#comment-17786163 ] Zhanghao Chen commented on FLINK-33263: --- [~yunta] Thanks for pointing out. I'll re

[jira] [Updated] (FLINK-33263) Implement ParallelismProvider for sources in the table planner

[ https://issues.apache.org/jira/browse/FLINK-33263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33263: -- Summary: Implement ParallelismProvider for sources in the table planner (was: Implement Paral

[jira] [Resolved] (FLINK-33146) FLIP-363: Unify the Representation of TaskManager Location in REST API and Web UI

[ https://issues.apache.org/jira/browse/FLINK-33146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen resolved FLINK-33146. --- Release Note: Unify the representation of TaskManager location in REST API and Web UI. The "

[jira] [Commented] (FLINK-27056) "pipeline.time-characteristic" should be deprecated and have EVENT_TIME as default value

[ https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786178#comment-17786178 ] Zhanghao Chen commented on FLINK-27056: --- [~libenchao] Thanks for your attention he

[jira] [Comment Edited] (FLINK-27056) "pipeline.time-characteristic" should be deprecated and have EVENT_TIME as default value

[ https://issues.apache.org/jira/browse/FLINK-27056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786178#comment-17786178 ] Zhanghao Chen edited comment on FLINK-27056 at 11/15/23 5:54 AM: -

[jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804987#comment-17804987 ] Zhanghao Chen commented on FLINK-34015: --- Hi [~Zakelly], I'm reaching out to you as

[jira] [Commented] (FLINK-34090) Introduce SerializerConfig for serialization

[ https://issues.apache.org/jira/browse/FLINK-34090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806875#comment-17806875 ] Zhanghao Chen commented on FLINK-34090: --- Hi [~zjureel], I'd be willing to take it,

[jira] [Commented] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

[ https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807014#comment-17807014 ] Zhanghao Chen commented on FLINK-33988: --- [~RocMarshal] Thanks for reporting this.

[jira] [Commented] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807045#comment-17807045 ] Zhanghao Chen commented on FLINK-34052: --- Thanks for reporting this, I'll take a lo

[jira] [Created] (FLINK-34103) AsyncIO example failed to run as DataGen Connector is not bundled

Zhanghao Chen created FLINK-34103: - Summary: AsyncIO example failed to run as DataGen Connector is not bundled Key: FLINK-34103 URL: https://issues.apache.org/jira/browse/FLINK-34103 Project: Flink

[jira] [Updated] (FLINK-34103) AsyncIO example failed to run as DataGen Connector is not bundled

[ https://issues.apache.org/jira/browse/FLINK-34103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34103: -- Description: >From the comments of FLINK-32821: root@73186f600374:/opt/flink# bin/flink run

[jira] [Commented] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807047#comment-17807047 ] Zhanghao Chen commented on FLINK-32821: --- FYI [~qinjunjerry] , I've created [FLINK-

[jira] [Updated] (FLINK-34103) AsyncIO example failed to run as DataGen Connector is not bundled

[ https://issues.apache.org/jira/browse/FLINK-34103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34103: -- External issue ID: FLINK-32821 > AsyncIO example failed to run as DataGen Connector is not bun

[jira] [Updated] (FLINK-34103) AsyncIO example failed to run as DataGen Connector is not bundled

[ https://issues.apache.org/jira/browse/FLINK-34103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34103: -- External issue ID: (was: FLINK-32821) > AsyncIO example failed to run as DataGen Connector i

[jira] [Comment Edited] (FLINK-34106) user defined source parallelism in ddl can't work if connector ScanRuntimeProvider is SourceFunctionProvider

[ https://issues.apache.org/jira/browse/FLINK-34106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807088#comment-17807088 ] Zhanghao Chen edited comment on FLINK-34106 at 1/16/24 7:54 AM: --

[jira] [Comment Edited] (FLINK-34106) user defined source parallelism in ddl can't work if connector ScanRuntimeProvider is SourceFunctionProvider

[ https://issues.apache.org/jira/browse/FLINK-34106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807088#comment-17807088 ] Zhanghao Chen edited comment on FLINK-34106 at 1/16/24 7:54 AM: --

[jira] [Commented] (FLINK-34106) user defined source parallelism in ddl can't work if connector ScanRuntimeProvider is SourceFunctionProvider

[ https://issues.apache.org/jira/browse/FLINK-34106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807088#comment-17807088 ] Zhanghao Chen commented on FLINK-34106: --- [~Akihito Liang] Are you refering to the

[jira] [Updated] (FLINK-34120) Introduce unified serialization config option for all Kryo, POJO and customized serializers

[ https://issues.apache.org/jira/browse/FLINK-34120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34120: -- Parent: FLINK-34037 Issue Type: Sub-task (was: New Feature) > Introduce unified seria

[jira] [Created] (FLINK-34120) Introduce unified serialization config option for all Kryo, POJO and customized serializers

Zhanghao Chen created FLINK-34120: - Summary: Introduce unified serialization config option for all Kryo, POJO and customized serializers Key: FLINK-34120 URL: https://issues.apache.org/jira/browse/FLINK-34120

[jira] [Created] (FLINK-34121) Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo

Zhanghao Chen created FLINK-34121: - Summary: Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo Key: FLINK-34121 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Created] (FLINK-34122) Deprecate old serialization config methods and options

Zhanghao Chen created FLINK-34122: - Summary: Deprecate old serialization config methods and options Key: FLINK-34122 URL: https://issues.apache.org/jira/browse/FLINK-34122 Project: Flink Issu

[jira] [Created] (FLINK-34123) Introduce built-in serializers for common composited data types

Zhanghao Chen created FLINK-34123: - Summary: Introduce built-in serializers for common composited data types Key: FLINK-34123 URL: https://issues.apache.org/jira/browse/FLINK-34123 Project: Flink

[jira] [Created] (FLINK-34124) Flink 2.0: Disable Kyro by default

Zhanghao Chen created FLINK-34124: - Summary: Flink 2.0: Disable Kyro by default Key: FLINK-34124 URL: https://issues.apache.org/jira/browse/FLINK-34124 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34125) Flink 2.0: Remove deprecated serialization config methods and options

Zhanghao Chen created FLINK-34125: - Summary: Flink 2.0: Remove deprecated serialization config methods and options Key: FLINK-34125 URL: https://issues.apache.org/jira/browse/FLINK-34125 Project: Flin

[jira] [Updated] (FLINK-34121) Flink 2.0: Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo

[ https://issues.apache.org/jira/browse/FLINK-34121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34121: -- Summary: Flink 2.0: Introduce pipeline.force-kryo-avro to control whether to force registratio

[jira] [Updated] (FLINK-34121) 2.0: Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo

[ https://issues.apache.org/jira/browse/FLINK-34121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34121: -- Affects Version/s: 2.0.0 (was: 1.19.0) Summary: 2.0: I

[jira] [Created] (FLINK-34217) Update Serialization-related doc with the new way of configuration

Zhanghao Chen created FLINK-34217: - Summary: Update Serialization-related doc with the new way of configuration Key: FLINK-34217 URL: https://issues.apache.org/jira/browse/FLINK-34217 Project: Flink

[jira] [Created] (FLINK-34230) Update flink-docs README: add -Pskip-webui-build to the config doc generation command

Zhanghao Chen created FLINK-34230: - Summary: Update flink-docs README: add -Pskip-webui-build to the config doc generation command Key: FLINK-34230 URL: https://issues.apache.org/jira/browse/FLINK-34230

[jira] [Updated] (FLINK-34230) Update flink-docs README: add -Pskip-webui-build to the config doc generation command

[ https://issues.apache.org/jira/browse/FLINK-34230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34230: -- Description: I used to generate Flink config docs with the command listed in flink-docs READM

[jira] [Updated] (FLINK-34230) Update flink-docs README: add -Pskip-webui-build to the config doc generation command

[ https://issues.apache.org/jira/browse/FLINK-34230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34230: -- Description: I used to generate Flink config docs with the command listed in flink-docs READM

[jira] [Commented] (FLINK-34230) Update flink-docs README: add -Pskip-webui-build to the config doc generation command

[ https://issues.apache.org/jira/browse/FLINK-34230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811104#comment-17811104 ] Zhanghao Chen commented on FLINK-34230: --- [~Weijie Guo] Could you help take a look

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

Zhanghao Chen created FLINK-34239: - Summary: Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl Key: FLINK-34239 URL: https://is

[jira] [Comment Edited] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811556#comment-17811556 ] Zhanghao Chen edited comment on FLINK-34052 at 1/27/24 4:25 PM: --

[jira] [Commented] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811556#comment-17811556 ] Zhanghao Chen commented on FLINK-34052: --- After invertigation, it turned out that t

[jira] [Comment Edited] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811556#comment-17811556 ] Zhanghao Chen edited comment on FLINK-34052 at 1/27/24 4:26 PM: --

[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&focusedCommentId=17811650#comment-17811650 ] Zhanghao Chen commented on FLINK-34239: --- [~mallikarjuna] Welcome to the community!

[jira] [Updated] (FLINK-34123) Introduce built-in serializers for common composited data types

[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34123: -- Affects Version/s: 1.19.0 > Introduce built-in serializers for common composited data types >

[jira] [Commented] (FLINK-34123) Introduce built-in serializers for common composited data types

[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811651#comment-17811651 ] Zhanghao Chen commented on FLINK-34123: --- [~zjureel] May I take this? I'll start wo

[jira] [Commented] (FLINK-24223) Client should throw exception to warn users when the configurations set by program options conflict with those set by -D

[ https://issues.apache.org/jira/browse/FLINK-24223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811710#comment-17811710 ] Zhanghao Chen commented on FLINK-24223: --- Closing it as Flink 2.0 has a plan to ref

[jira] [Closed] (FLINK-24223) Client should throw exception to warn users when the configurations set by program options conflict with those set by -D

[ https://issues.apache.org/jira/browse/FLINK-24223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen closed FLINK-24223. - Resolution: Later > Client should throw exception to warn users when the configurations set by

[jira] [Commented] (FLINK-33261) FLIP-367: Support Setting Parallelism for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812146#comment-17812146 ] Zhanghao Chen commented on FLINK-33261: --- [~lincoln.86xy] Thanks for the attention.

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

[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33265: -- Parent: (was: FLINK-33261) Issue Type: New Feature (was: Sub-task) > Support sour

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

[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33265: -- Description: The kafka connector adaptation work for [FLIP-367: Support Setting Parallelism fo

[jira] [Created] (FLINK-34270) Update connector developer-facing doc

Zhanghao Chen created FLINK-34270: - Summary: Update connector developer-facing doc Key: FLINK-34270 URL: https://issues.apache.org/jira/browse/FLINK-34270 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-34270) Update connector developer-facing doc

[ https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34270: -- Description: Update the 'extension points' on User-defined Sources & Sinks page ([https://nig

[jira] [Updated] (FLINK-34270) Update connector developer-facing doc

[ https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34270: -- Fix Version/s: 1.19.0 > Update connector developer-facing doc > --

[jira] [Updated] (FLINK-34121) Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo

[ https://issues.apache.org/jira/browse/FLINK-34121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34121: -- Affects Version/s: 1.19.0 (was: 2.0.0) > Introduce pipeline.force-k

[jira] [Updated] (FLINK-34121) Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo

[ https://issues.apache.org/jira/browse/FLINK-34121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34121: -- Summary: Introduce pipeline.force-kryo-avro to control whether to force registration of Avro s

[jira] [Commented] (FLINK-34122) Deprecate old serialization config methods and options

[ https://issues.apache.org/jira/browse/FLINK-34122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812294#comment-17812294 ] Zhanghao Chen commented on FLINK-34122: --- [~martijnvisser] Sure, shall I put the re

[jira] [Updated] (FLINK-34270) Update connector developer-facing doc for FLIP-367

[ https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34270: -- Summary: Update connector developer-facing doc for FLIP-367 (was: Update connector developer-

[jira] [Updated] (FLINK-34270) Update connector developer-facing doc for FLIP-367 & 146

[ https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34270: -- Summary: Update connector developer-facing doc for FLIP-367 & 146 (was: Update connector deve

[jira] [Updated] (FLINK-34270) Update connector developer-facing doc for FLIP-367 & 146

[ https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34270: -- Description: Update the 'extension points' on User-defined Sources & Sinks page ([https://nig

[jira] [Updated] (FLINK-34122) Deprecate old serialization config methods and options

[ https://issues.apache.org/jira/browse/FLINK-34122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34122: -- Release Note: Configuring serialization behavior through hard codes is deprecated, because you

[jira] [Updated] (FLINK-33261) FLIP-367: Support Setting Parallelism for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33261: -- Release Note: Scan table sources can now be set a custom parallelism for performance tuning vi

[jira] [Updated] (FLINK-33221) Add config options for administrator JVM options

[ https://issues.apache.org/jira/browse/FLINK-33221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33221: -- Release Note: A set of administrator JVM options are available, which prepend the user-set ext

[jira] [Commented] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813025#comment-17813025 ] Zhanghao Chen commented on FLINK-34305: --- [~sudewei.sdw] Could you help prepare a t

[jira] [Created] (FLINK-34328) Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink

Zhanghao Chen created FLINK-34328: - Summary: Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink Key: FLINK-34328 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Commented] (FLINK-34328) Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink

[ https://issues.apache.org/jira/browse/FLINK-34328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813026#comment-17813026 ] Zhanghao Chen commented on FLINK-34328: --- It needs cross-team testing. [~lincoln.86

[jira] [Commented] (FLINK-33575) FLIP-394: Add Metrics for Connector Agnostic Autoscaling

[ https://issues.apache.org/jira/browse/FLINK-33575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813042#comment-17813042 ] Zhanghao Chen commented on FLINK-33575: --- [~mason6345] Hi, we also need this featur

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

Zhanghao Chen created FLINK-34354: - Summary: Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink Key: FLINK-34354 URL: https://issues.apache.org/jira/browse/FLINK-34354

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Priority: Blocker (was: Major) > Release Testing: Verify FLINK-34037 Improve Serialization Co

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: Volunteers can verify it by following the [doc changes|https://github.com/apache

[jira] [Updated] (FLINK-34328) Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink

[ https://issues.apache.org/jira/browse/FLINK-34328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34328: -- Priority: Blocker (was: Major) > Release Testing Instructions: Verify FLINK-34037 Improve Ser

[jira] [Closed] (FLINK-34328) Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink

[ https://issues.apache.org/jira/browse/FLINK-34328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen closed FLINK-34328. - Resolution: Fixed > Release Testing Instructions: Verify FLINK-34037 Improve Serialization > Co

[jira] [Updated] (FLINK-34123) Introduce built-in serializers for common composited data types

[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34123: -- Description: To be implemented in v1.20. > Introduce built-in serializers for common composite

[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&focusedCommentId=17814181#comment-17814181 ] Zhanghao Chen commented on FLINK-33265: --- Hi [~lincoln.86xy], SuDewei will be doing

[jira] [Commented] (FLINK-33240) Generate docs for deprecated options as well

[ https://issues.apache.org/jira/browse/FLINK-33240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814182#comment-17814182 ] Zhanghao Chen commented on FLINK-33240: --- Closing it for duplication. The effort is

[jira] [Closed] (FLINK-33240) Generate docs for deprecated options as well

[ https://issues.apache.org/jira/browse/FLINK-33240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen closed FLINK-33240. - Fix Version/s: (was: 1.19.0) Resolution: Duplicate > Generate docs for deprecated opt

[jira] [Commented] (FLINK-34392) Release Testing Instructions: Verify FLINK-33146 Unify the Representation of TaskManager Location in REST API and Web UI

[ https://issues.apache.org/jira/browse/FLINK-34392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815086#comment-17815086 ] Zhanghao Chen commented on FLINK-34392: --- Closing it as it does not require cross-t

[jira] [Commented] (FLINK-34392) Release Testing Instructions: Verify FLINK-33146 Unify the Representation of TaskManager Location in REST API and Web UI

[ https://issues.apache.org/jira/browse/FLINK-34392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815087#comment-17815087 ] Zhanghao Chen commented on FLINK-34392: --- [~lincoln.86xy] Hi, I cannot close it. Co

[jira] [Commented] (FLINK-33962) Chaining-agnostic OperatorID generation for improved state compatibility on parallelism change

[ https://issues.apache.org/jira/browse/FLINK-33962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815195#comment-17815195 ] Zhanghao Chen commented on FLINK-33962: --- Hi [~srichter], I'm trying to make the ha

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

Zhanghao Chen created FLINK-33681: - Summary: Display source/sink numRecordsIn/Out & numBytesIn/Out on UI Key: FLINK-33681 URL: https://issues.apache.org/jira/browse/FLINK-33681 Project: Flink

[jira] [Created] (FLINK-33682) Reuse source operator input records/bytes metrics for SourceOperatorStreamTask

Zhanghao Chen created FLINK-33682: - Summary: Reuse source operator input records/bytes metrics for SourceOperatorStreamTask Key: FLINK-33682 URL: https://issues.apache.org/jira/browse/FLINK-33682 Proj

[jira] [Created] (FLINK-33891) Remove the obsolete SingleJobGraphStore

Zhanghao Chen created FLINK-33891: - Summary: Remove the obsolete SingleJobGraphStore Key: FLINK-33891 URL: https://issues.apache.org/jira/browse/FLINK-33891 Project: Flink Issue Type: Technic

[jira] [Commented] (FLINK-33891) Remove the obsolete SingleJobGraphStore

[ https://issues.apache.org/jira/browse/FLINK-33891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798819#comment-17798819 ] Zhanghao Chen commented on FLINK-33891: --- [~huweihua] Could you help take a look?

[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&focusedCommentId=17800174#comment-17800174 ] Zhanghao Chen commented on FLINK-33681: --- After further investigation, it turned ou

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33681: -- Affects Version/s: 1.17.2 1.18.0 Issue Type: Bug (was: Impro

[jira] [Comment Edited] (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&focusedCommentId=17800174#comment-17800174 ] Zhanghao Chen edited comment on FLINK-33681 at 12/24/23 12:24 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-33681 ] Zhanghao Chen deleted comment on FLINK-33681: --- was (Author: zhanghao chen): After further investigation, it turned out to be a bug introduced by FLINK-30536, which changed the way to count

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33681: -- Attachment: (was: image-2023-11-29-13-26-15-176.png) > Display source/sink numRecordsIn/Ou

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33681: -- Attachment: screenshot-20231224-195605-1.png Description: Currently, the numRecordsIn & n

  1   2   3   4   >