[ANNOUNCE] Apache Flink-shaded 19.0 released

2024-07-09 Thread Dawid Wysakowicz
The Apache Flink community is very happy to announce the release of Apache Flink-shaded 19.0. The flink-shaded project contains a number of shaded dependencies for Apache Flink. Apache FlinkĀ® is an open-source stream processing framework for distributed, high-performing, always-available, and acc

[jira] [Created] (FLINK-35793) BatchSQLTest.testBatchSQL failed in hybrid shuffle selective mode

2024-07-09 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35793: -- Summary: BatchSQLTest.testBatchSQL failed in hybrid shuffle selective mode Key: FLINK-35793 URL: https://issues.apache.org/jira/browse/FLINK-35793 Project: Flink

[jira] [Created] (FLINK-35794) Ability to skip kubernetes tests in e2e nightly test script

2024-07-09 Thread David Kornel (Jira)
David Kornel created FLINK-35794: Summary: Ability to skip kubernetes tests in e2e nightly test script Key: FLINK-35794 URL: https://issues.apache.org/jira/browse/FLINK-35794 Project: Flink

RE: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-07-09 Thread David Radley
Hi Kevin, I have agreed a design with Chesnay and Danny. I am implementing a prototype, to prove it works, then will update the Flip text with the new design. Initial testing is showing it working. Here is a quick history so you can understand our current thinking. 1. Initially we passed ma

[jira] [Created] (FLINK-35795) FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-07-09 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-35795: --- Summary: FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2 Key: FLINK-35795 URL: https://issues.apache.org/jira/browse/FLINK-35795 Project: Flink

[SUMMARY] Flink 1.20 Release Sync 07/09/2024

2024-07-09 Thread weijie guo
Dear devs, This is the fourth meeting after feature freeze of Flink 1.20. I'd like to share the information synced in the meeting. - *Timeline* Flink 1.20 doesn't have any blocker for now. We plan to create and vote the release-1.20.0-rc1 next monday if we're not aware of any new blocker.

[jira] [Created] (FLINK-35796) Ensure that MailboxExecutor.submit is used correctly

2024-07-09 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-35796: --- Summary: Ensure that MailboxExecutor.submit is used correctly Key: FLINK-35796 URL: https://issues.apache.org/jira/browse/FLINK-35796 Project: Flink Issue Type

[jira] [Created] (FLINK-35797) FLIP-456: CompiledPlan support for Batch Execution Mode

2024-07-09 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35797: -- Summary: FLIP-456: CompiledPlan support for Batch Execution Mode Key: FLINK-35797 URL: https://issues.apache.org/jira/browse/FLINK-35797 Project: Flink Issue Typ

[jira] [Created] (FLINK-35798) Implement a BatchCompiledPlanTestBase

2024-07-09 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35798: -- Summary: Implement a BatchCompiledPlanTestBase Key: FLINK-35798 URL: https://issues.apache.org/jira/browse/FLINK-35798 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35799) Add CompiledPlan annotations to BatchExecCalc

2024-07-09 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35799: -- Summary: Add CompiledPlan annotations to BatchExecCalc Key: FLINK-35799 URL: https://issues.apache.org/jira/browse/FLINK-35799 Project: Flink Issue Type: Sub-tas

Static OpenSSL lib licensing

2024-07-09 Thread Robert Young
Hi, I see in flink-shaded main we depend on 2.0.62.Final and we currently avoid building/distributing flink-shaded-netty-tcnative-static due to legal issues > This module is excluded by default since it is not compliant with the apache license. https://issues.apache.org/jira/browse/LEGAL-393 net

[jira] [Created] (FLINK-35800) Update chinese documentation for json_(un)quote function

2024-07-09 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-35800: --- Summary: Update chinese documentation for json_(un)quote function Key: FLINK-35800 URL: https://issues.apache.org/jira/browse/FLINK-35800 Project: Flink

[jira] [Created] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-07-09 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35801: -- Summary: testSwitchFromEnablingToDisablingFileMerging failed in AZP Key: FLINK-35801 URL: https://issues.apache.org/jira/browse/FLINK-35801 Project: Flink Issue

Kafka Connector Consulting: Why there is no limit size of Kafka producer pool in KafkaWriter

2024-07-09 Thread Rascal Wu
Hi, May I consult one question about why there is no limit size of `producerPool` in KafkaWriter. It seems that the current logical will create a new producer during create KafkaWriter and start checkpoint(snapshotState been invoked) if the producer pool is empty, and then add the producer into po

[jira] [Created] (FLINK-35802) Deadlock may happen after adding new tables

2024-07-09 Thread LvYanquan (Jira)
LvYanquan created FLINK-35802: - Summary: Deadlock may happen after adding new tables Key: FLINK-35802 URL: https://issues.apache.org/jira/browse/FLINK-35802 Project: Flink Issue Type: Bug