[jira] [Created] (FLINK-35406) Use inner serializer when casting RAW type to BINARY or STRING in cast rules

Zhenghua Gao created FLINK-35406: Summary: Use inner serializer when casting RAW type to BINARY or STRING in cast rules Key: FLINK-35406 URL: https://issues.apache.org/jira/browse/FLINK-35406 Project:

[jira] [Created] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController

Yanfei Lei created FLINK-35405: -- Summary: Add buffer size/in-flight records metrics for AsyncExecutionController Key: FLINK-35405 URL: https://issues.apache.org/jira/browse/FLINK-35405 Project: Flink

[RESULT][VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0

Hi devs, I'm happy to announce that FLIP-450: Improve Runtime Configuration for Flink 2.0[1] has been accepted with 3 approving votes (3 bindings) [2]: - Rui Fan (binding) - Weijie Guo (binding) - Xintong Song (binding) There are no disapproving votes. Thanks again to everyone who participated

Re: [VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0

Hi all, Thank you all! Closing the vote. The result will be announced in a separate email. Best regards, Xuannan On Thu, May 16, 2024 at 10:05 AM Xintong Song wrote: > > +1 (binding) > > Best, > > Xintong > > > > On Wed, May 15, 2024 at 6:53 PM weijie guo > wrote: > > > +1(binding) > > > > Bes

[jira] [Created] (FLINK-35404) Report metrics of KafkaConsumer in new Kafka source

Harshit Mittal created FLINK-35404: -- Summary: Report metrics of KafkaConsumer in new Kafka source Key: FLINK-35404 URL: https://issues.apache.org/jira/browse/FLINK-35404 Project: Flink Issue

[jira] [Created] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding

Alan Sheinberg created FLINK-35403: -- Summary: FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding Key: FLINK-35403 URL: https://issues.apache.org/jira/browse/FLINK-35403 Proj

[jira] [Created] (FLINK-35402) [flink-operator][Deployment] add labels to metadata

Luís Costa created FLINK-35402: -- Summary: [flink-operator][Deployment] add labels to metadata Key: FLINK-35402 URL: https://issues.apache.org/jira/browse/FLINK-35402 Project: Flink Issue Type: I

Re: [DISCUSS] FLIP-451: Refactor Async sink API

Hi Ahmed, Thanks for putting this together! Should we still be marking getFatalExceptionCons() as @Deprecated in this FLIP, if we are not providing a replacement? Regards, Hong On Mon, May 13, 2024 at 7:58 PM Ahmed Hamdy wrote: > Hi David, > yes there error classification was initially left to

[jira] [Created] (FLINK-35401) Add SQS Table API support

Ahmed Hamdy created FLINK-35401: --- Summary: Add SQS Table API support Key: FLINK-35401 URL: https://issues.apache.org/jira/browse/FLINK-35401 Project: Flink Issue Type: New Feature Com

AppClassLoader leakage to MiniCluster

Hi, I was investigating a problem in Apache Beam test infrastructure after introduction of FlinkRunner for Flink 1.18 (see [1]). There was a persistent failure of integration test which uses `mvn exec:java` to run a word count example. The test (for FlinkRunner) uses MiniCluster and works fin