[jira] [Created] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

2023-05-26 Thread Oleksandr Nitavskyi (Jira)
Oleksandr Nitavskyi created FLINK-32203: --- Summary: Potential ClassLoader memory leak due to log4j configuration Key: FLINK-32203 URL: https://issues.apache.org/jira/browse/FLINK-32203 Project: F

[jira] [Created] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

2023-05-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32204: --- Summary: ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP Key: FLINK-32204

[jira] [Created] (FLINK-32205) Flink Rest Client should support connecting to the server using URLs.

2023-05-26 Thread Weihua Hu (Jira)
Weihua Hu created FLINK-32205: - Summary: Flink Rest Client should support connecting to the server using URLs. Key: FLINK-32205 URL: https://issues.apache.org/jira/browse/FLINK-32205 Project: Flink

[DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

2023-05-26 Thread Shammon FY
Hi devs, We would like to bring up a discussion about FLIP-294: Support Customized Job Meta Data Listener[1]. We have had several discussions with Jark Wu, Leonard Xu, Dong Lin, Qingsheng Ren and Poorvank about the functions and interfaces, and thanks for their valuable advice. The overall job and

[ANNOUNCE] Apache Flink 1.16.2 released

2023-05-26 Thread weijie guo
The Apache Flink community is very happy to announce the release of Apache Flink 1.16.2, which is the second bugfix release for the Apache Flink 1.16 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streamin

[ANNOUNCE] Apache Flink 1.17.1 released

2023-05-26 Thread weijie guo
The Apache Flink community is very happy to announce the release of Apache Flink 1.17.1, which is the first bugfix release for the Apache Flink 1.17 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[jira] [Created] (FLINK-32206) Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch

2023-05-26 Thread Alireza Omidvar (Jira)
Alireza Omidvar created FLINK-32206: --- Summary: Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch Key: FLINK-32206 URL: https://issues.apache.org/jira/browse/FLINK-32206

[jira] [Created] (FLINK-32207) Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch

2023-05-26 Thread Alireza Omidvar (Jira)
Alireza Omidvar created FLINK-32207: --- Summary: Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch Key: FLINK-32207 URL: https://issues.apache.org/jira/browse/FLINK-32207

Re: [ANNOUNCE] Apache Flink 1.16.2 released

2023-05-26 Thread Martijn Visser
Thank you Weijie and those who helped with testing! On Fri, May 26, 2023 at 1:06 PM weijie guo wrote: > The Apache Flink community is very happy to announce the release of > Apache Flink 1.16.2, which is the second bugfix release for the Apache > Flink 1.16 series. > > > > Apache Flink® is an op

Re: [ANNOUNCE] Apache Flink 1.17.1 released

2023-05-26 Thread Martijn Visser
Same here as with Flink 1.16.2, thank you Weijie and those who helped with testing! On Fri, May 26, 2023 at 1:08 PM weijie guo wrote: > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.17.1, which is the first bugfix release for the Apache Flink 1.17 > ser

[jira] [Created] (FLINK-32208) Remove dependency on flink-shaded from flink-connector-aws

2023-05-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32208: --- Summary: Remove dependency on flink-shaded from flink-connector-aws Key: FLINK-32208 URL: https://issues.apache.org/jira/browse/FLINK-32208 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.17.1 released

2023-05-26 Thread Jing Ge
Hi Weijie, That is earlier than I expected! Thank you so much for your effort! Best regards, Jing On Fri, May 26, 2023 at 4:44 PM Martijn Visser wrote: > Same here as with Flink 1.16.2, thank you Weijie and those who helped with > testing! > > On Fri, May 26, 2023 at 1:08 PM weijie guo > wrot

Re: [ANNOUNCE] Apache Flink 1.16.2 released

2023-05-26 Thread Jing Ge
Hi Weijie, Thanks again for your effort. I was wondering if there were any obstacles you had to overcome while releasing 1.16.2 and 1.17.1 that could lead us to any improvement wrt the release process and management? Best regards, Jing On Fri, May 26, 2023 at 4:41 PM Martijn Visser wrote: > Th

[jira] [Created] (FLINK-32209) Opensearch connector should remove the dependency on flink-shaded

2023-05-26 Thread Andriy Redko (Jira)
Andriy Redko created FLINK-32209: Summary: Opensearch connector should remove the dependency on flink-shaded Key: FLINK-32209 URL: https://issues.apache.org/jira/browse/FLINK-32209 Project: Flink

Re: [DISCUSS] FLIP-312: Add Yarn ACLs to Flink Containers

2023-05-26 Thread Archit Goyal
Thanks Yang for review. 1. FLIP-312 relies on Hadoop version 2.6.0 or later. 2. I have updated the FLIP and made it more descriptive. 3. ACLs apply to logs as well as permissions to kill the application. Also, in the PR we are setting ACLs for Task Manager (createTaskExecutorContext) as

Re: Questions on checkpointing mechanism for FLIP-27 Source API

2023-05-26 Thread Jing Ge
Hi Hong, Great question! Afaik, it depends on the implementation. Speaking of the "loopback" event sending to the SplitEnumerator, I guess you meant here [1] (It might be good, if you could point out the right position in the source code to help us understand the question better:)), which will end

Re: [DISCUSS] FLIP-313 Add support of User Defined AsyncTableFunction

2023-05-26 Thread Jing Ge
Hi Aitozi, Thanks for your proposal. I am not quite sure if I understood your thoughts correctly. You described a special case implementation of the AsyncTableFunction with on public API changes. Would you please elaborate your purpose of writing a FLIP according to the FLIP documentation[1]? Than

Re: [DISCUSS] Status of Statefun Project

2023-05-26 Thread Galen Warren
Ok, I get it. No interest. If this project is being abandoned, I guess I'll work with my own fork. Is there anything I should consider here? Can I share it with other people who use this project? On Tue, May 16, 2023 at 10:50 AM Galen Warren wrote: > Hi Martijn, since you opened this discussion