Re: [DISCUSS] Release Flink 1.16.1

2022-12-18 Thread Lincoln Lee
Hi Martijn, +1 Thank you for bringing this up. Regarding the temporal table join, three related bugs were recently discovered, all causing data correctness issues, including: https://issues.apache.org/jira/browse/FLINK-29781 (merged & picked) https://issues.apache.org/jira/browse/FLINK-28988 (mer

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-12-18 Thread Hang Ruan
Congratulations, Godfrey and Xingbo! Jun Qin 于2022年12月17日周六 03:52写道: > Congratulations to both of you, Godfrey and Xingbo! > > > On Nov 25, 2022, at 1:29 AM, Dong Lin wrote: > > > > Congratulations, Godfrey and Xingbo! > > > > > > On Wed, Nov 23, 2022 at 12:19 PM Dian Fu wrote: > > > >> Hi eve

[jira] [Created] (FLINK-30449) Improve Serialization and Deserialization of FetchResultsResponseBody

2022-12-18 Thread yuzelin (Jira)
yuzelin created FLINK-30449: --- Summary: Improve Serialization and Deserialization of FetchResultsResponseBody Key: FLINK-30449 URL: https://issues.apache.org/jira/browse/FLINK-30449 Project: Flink

Re: [DISCUSS] FLIP-278: Hybrid Source Connector

2022-12-18 Thread John Roesler
Hello all, Thanks for the FLIP, Ran! The HybridSource is a really cool feature, and I was glad to see a proposal to expose it in the Table and SQL APIs. My main question is also about the switching control (question 2). It seems like the existing Kafka connector has all the options you'd want

[jira] [Created] (FLINK-30450) FileSystem supports exporting client-side metrics

2022-12-18 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-30450: Summary: FileSystem supports exporting client-side metrics Key: FLINK-30450 URL: https://issues.apache.org/jira/browse/FLINK-30450 Project: Flink Issue Type:

Re: [VOTE] Update Flink's Scala 2.12 support from 2.12.7 to 2.12.16

2022-12-18 Thread ConradJam
+1 (non-binding) Sergey Nuyanzin 于2022年12月18日周日 15:42写道: > +1 (non-binding) > > On Sat, Dec 17, 2022 at 1:06 PM David Anderson > wrote: > > > +1 (binding) > > > > > > > > On Fri, Dec 16, 2022 at 12:22 PM Martijn Visser < > martijnvis...@apache.org> > > wrote: > > > > > Hi all, > > > > > > I'm b

[jira] [Created] (FLINK-30451) Add Estimator and Transformer for Swing

2022-12-18 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30451: - Summary: Add Estimator and Transformer for Swing Key: FLINK-30451 URL: https://issues.apache.org/jira/browse/FLINK-30451 Project: Flink Issue Type: New Fea

[jira] [Created] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
luoyuxia created FLINK-30452: Summary: Wrong argument type is used when call Hive's function Key: FLINK-30452 URL: https://issues.apache.org/jira/browse/FLINK-30452 Project: Flink Issue Type: Bug

[DISCUSS] FLIP-266: Simplify network memory configurations for TaskManager

2022-12-18 Thread Yuxin Tan
Hi, devs, I'd like to start a discussion about FLIP-266: Simplify network memory configurations for TaskManager[1]. When using Flink, users may encounter the following issues that affect usability. 1. The job may fail with an "Insufficient number of network buffers" exception. 2. Flink network me