[jira] [Created] (FLINK-35774) The cache of transform is not updated after process schema change event

Wenkai Qi created FLINK-35774: - Summary: The cache of transform is not updated after process schema change event Key: FLINK-35774 URL: https://issues.apache.org/jira/browse/FLINK-35774 Project: Flink

Potential Kafka Connector FLIP: Large Message Handling

Hi all, Writing to see if the community would be open to exploring a FLIP for the Kafka Table Connectors. The FLIP would allow for storing Kafka Messages beyond a Kafka cluster's message limit (1 MB by default) out of band in cloud object storage or another backend. During serialization the messa

[jira] [Created] (FLINK-35773) Document s5cmd

Piotr Nowojski created FLINK-35773: -- Summary: Document s5cmd Key: FLINK-35773 URL: https://issues.apache.org/jira/browse/FLINK-35773 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-35772) Deprecate/remove DuplicatingFileSystem

Piotr Nowojski created FLINK-35772: -- Summary: Deprecate/remove DuplicatingFileSystem Key: FLINK-35772 URL: https://issues.apache.org/jira/browse/FLINK-35772 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35771) Limit s5cmd resource usage

Piotr Nowojski created FLINK-35771: -- Summary: Limit s5cmd resource usage Key: FLINK-35771 URL: https://issues.apache.org/jira/browse/FLINK-35771 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35770) Interrupt s5cmd call on cancellation

Piotr Nowojski created FLINK-35770: -- Summary: Interrupt s5cmd call on cancellation Key: FLINK-35770 URL: https://issues.apache.org/jira/browse/FLINK-35770 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-35769) State files might not be deleted on task cancellation

Roman Khachatryan created FLINK-35769: - Summary: State files might not be deleted on task cancellation Key: FLINK-35769 URL: https://issues.apache.org/jira/browse/FLINK-35769 Project: Flink

Re: [2.0] How to handle on-going feature development in Flink 2.0?

Thanks for the feedback. I went ahead and added a list for new features [1] to the end of the 2.0 release page. That enables us to document such changes. I hope that's ok for the 2.0 release manager. Feel free to revert my changes if you have anything else in mind. Best, Matthias [1] https://cwik

[jira] [Created] (FLINK-35768) Use native file copy in RocksDBStateDownloader

Piotr Nowojski created FLINK-35768: -- Summary: Use native file copy in RocksDBStateDownloader Key: FLINK-35768 URL: https://issues.apache.org/jira/browse/FLINK-35768 Project: Flink Issue Type

[jira] [Created] (FLINK-35767) Provide native file copy support for S3 using s5cmd

Piotr Nowojski created FLINK-35767: -- Summary: Provide native file copy support for S3 using s5cmd Key: FLINK-35767 URL: https://issues.apache.org/jira/browse/FLINK-35767 Project: Flink Issue

[jira] [Created] (FLINK-35766) When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs

Junrui Li created FLINK-35766: - Summary: When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs Key: FLINK-35766 URL: https://issues.apache.org/jira/browse/FLINK-35766

[jira] [Created] (FLINK-35765) Support Fine Grained Resource Specifications for Adaptive Scheduler

RocMarshal created FLINK-35765: -- Summary: Support Fine Grained Resource Specifications for Adaptive Scheduler Key: FLINK-35765 URL: https://issues.apache.org/jira/browse/FLINK-35765 Project: Flink

[jira] [Created] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

Liu Liu created FLINK-35764: --- Summary: TimerGauge is incorrect when update is called during a measurement Key: FLINK-35764 URL: https://issues.apache.org/jira/browse/FLINK-35764 Project: Flink Iss

[jira] [Created] (FLINK-35763) Bump Java version

911432 created FLINK-35763: -- Summary: Bump Java version Key: FLINK-35763 URL: https://issues.apache.org/jira/browse/FLINK-35763 Project: Flink Issue Type: Improvement Affects Versions: 1.20.0