[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=17800234#comment-17800234 ] Zhanghao Chen edited comment on FLINK-33681 at 12/25/23 5:39 AM: -

[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

[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: -- Description: Currently, the numRecordsIn & numBytesIn metrics for sources and the

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

[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

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

[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=17800174#comment-17800174 ] Zhanghao Chen commented on FLINK-33681: --- After further investigation, it turned out that it is a

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

[jira] [Updated] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33940: -- Description: *Background* The choice of the max parallelism of an stateful operator is

[jira] [Commented] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800444#comment-17800444 ] Zhanghao Chen commented on FLINK-33940: --- Thanks [~gyfora] for pointing that. We also observe some

[jira] [Created] (FLINK-33940) Update Update the auto-derivation rule of max parallelism for enlarged upscaling space

Zhanghao Chen created FLINK-33940: - Summary: Update Update the auto-derivation rule of max parallelism for enlarged upscaling space Key: FLINK-33940 URL: https://issues.apache.org/jira/browse/FLINK-33940

[jira] [Updated] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33940: -- Summary: Update the auto-derivation rule of max parallelism for enlarged upscaling space

[jira] [Commented] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800420#comment-17800420 ] Zhanghao Chen commented on FLINK-33940: --- Here I'm proposing to

[jira] [Commented] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800413#comment-17800413 ] Zhanghao Chen commented on FLINK-33940: --- cc [~mxm] [~fanrui] Looking forward to the opinions from

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

[ https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800697#comment-17800697 ] Zhanghao Chen commented on FLINK-33682: --- Closing this ticket as we found a better unified

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

[ https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen closed FLINK-33682. - Resolution: Abandoned > Reuse source operator input records/bytes metrics for

[jira] [Commented] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801815#comment-17801815 ] Zhanghao Chen commented on FLINK-33940: --- [~mxm] There's no concrete rationale for selecting the

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33962: -- Description: *Background* Flink restores opeartor state from snapshots based on matching the

[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=17801746#comment-17801746 ] Zhanghao Chen commented on FLINK-33962: --- Hi [~xtsong], reaching out to you as I think it'll be

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

Zhanghao Chen created FLINK-33962: - Summary: Chaining-agnostic OperatorID generation for improved state compatibility on parallelism change Key: FLINK-33962 URL: https://issues.apache.org/jira/browse/FLINK-33962

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33962: -- Description: *Background* Flink restores opeartor state from snapshots based on matching the

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33962: -- Description: *Background* Flink restores opeartor state from snapshots based on matching the

[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=17801984#comment-17801984 ] Zhanghao Chen commented on FLINK-33962: --- Thanks for the quick response, I'll draft a FLIP and

[jira] [Commented] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

[ https://issues.apache.org/jira/browse/FLINK-33940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801987#comment-17801987 ] Zhanghao Chen commented on FLINK-33940: --- [~mxm] thanks for the quick response, I'll update with

[jira] [Commented] (FLINK-33940) Update the auto-derivation rule of max parallelism for enlarged upscaling space

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

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33977: -- Component/s: Runtime / Coordination > Adaptive scheduler may not minimize the number of TMs

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

Zhanghao Chen created FLINK-33977: - Summary: Adaptive scheduler may not minimize the number of TMs during downscaling Key: FLINK-33977 URL: https://issues.apache.org/jira/browse/FLINK-33977 Project:

[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=17804987#comment-17804987 ] Zhanghao Chen commented on FLINK-34015: --- Hi [~Zakelly], I'm reaching out to you as you've

[jira] [Commented] (FLINK-33325) FLIP-375: Built-in cross-platform powerful java profiler

[ https://issues.apache.org/jira/browse/FLINK-33325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804598#comment-17804598 ] Zhanghao Chen commented on FLINK-33325: --- Looking forward to the feature~ > FLIP-375: Built-in

[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=17804596#comment-17804596 ] Zhanghao Chen commented on FLINK-33681: --- [~renqs] Kindly remind~ Would you mind take a look at the

[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=17807014#comment-17807014 ] Zhanghao Chen commented on FLINK-33988: --- [~RocMarshal] Thanks for reporting this. You are right,

[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=17807045#comment-17807045 ] Zhanghao Chen commented on FLINK-34052: --- Thanks for reporting this, I'll take a look. [~huweihua]

[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=17807047#comment-17807047 ] Zhanghao Chen commented on FLINK-32821: --- FYI [~qinjunjerry] , I've created [FLINK-34103] AsyncIO

[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=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=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=17807088#comment-17807088 ] Zhanghao Chen commented on FLINK-34106: --- [~Akihito Liang] Are you refering to the new API

[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

[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

[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

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

[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=17806875#comment-17806875 ] Zhanghao Chen commented on FLINK-34090: --- Hi [~zjureel], I'd be willing to take it, could you

[jira] [Updated] (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:all-tabpanel ] Zhanghao Chen updated FLINK-33977: -- Component/s: Autoscaler > Adaptive scheduler may not minimize the number of TMs during

[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: -- Fix Version/s: 1.19.0 > Add config options for administrator JVM options >

[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

[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] [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=17811556#comment-17811556 ] Zhanghao Chen edited comment on FLINK-34052 at 1/27/24 4:25 PM: After

[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=17811556#comment-17811556 ] Zhanghao Chen edited comment on FLINK-34052 at 1/27/24 4:26 PM: After

[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=17811556#comment-17811556 ] Zhanghao Chen commented on FLINK-34052: --- After invertigation, it turned out that the issue was

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

[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=17811104#comment-17811104 ] Zhanghao Chen commented on FLINK-34230: --- [~Weijie Guo] Could you help take a look when you are

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

[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=17811651#comment-17811651 ] Zhanghao Chen commented on FLINK-34123: --- [~zjureel] May I take this? I'll start working on it

[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-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=17811710#comment-17811710 ] Zhanghao Chen commented on FLINK-24223: --- Closing it as Flink 2.0 has a plan to refactor the CLI

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

[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=17813025#comment-17813025 ] Zhanghao Chen commented on FLINK-34305: --- [~sudewei.sdw] Could you help prepare a testing

[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=17813026#comment-17813026 ] Zhanghao Chen commented on FLINK-34328: --- It needs cross-team testing. [~lincoln.86xy] Could you

[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=17813042#comment-17813042 ] Zhanghao Chen commented on FLINK-33575: --- [~mason6345] Hi, we also need this feature, what are the

[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

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

[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

[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

[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

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

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

[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] [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=17812146#comment-17812146 ] Zhanghao Chen commented on FLINK-33261: --- [~lincoln.86xy] Thanks for the attention. I'll transfer

[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

[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

[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

[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

[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

[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=17812294#comment-17812294 ] Zhanghao Chen commented on FLINK-34122: --- [~martijnvisser] Sure, shall I put the release notes info

[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

[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=17814182#comment-17814182 ] Zhanghao Chen commented on FLINK-33240: --- Closing it for duplication. The effort is postponed due

[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

[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

[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

[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

[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=17786163#comment-17786163 ] Zhanghao Chen commented on FLINK-33263: --- [~yunta] Thanks for pointing out. I'll rephrase it as

[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

[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=17786178#comment-17786178 ] Zhanghao Chen commented on FLINK-27056: --- [~libenchao] Thanks for your attention here. The option's

[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=17786178#comment-17786178 ] Zhanghao Chen edited comment on FLINK-27056 at 11/15/23 5:54 AM: -

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

[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

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

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

[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-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] [Commented] (FLINK-35145) Add timeout for cluster termination

[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838219#comment-17838219 ] Zhanghao Chen commented on FLINK-35145: --- [~fangyong] [~huweihua] WDYT about this? > Add timeout

[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] [Created] (FLINK-35145) Add timeout for cluster termination

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:

<    1   2   3   4   >