[jira] [Created] (FLINK-29216) rows belong to update rowkind are transfered into delete and insert

2022-09-06 Thread Spongebob (Jira)
Spongebob created FLINK-29216: - Summary: rows belong to update rowkind are transfered into delete and insert Key: FLINK-29216 URL: https://issues.apache.org/jira/browse/FLINK-29216 Project: Flink

Re: redis subscriber source

2022-09-06 Thread Peng Kang
It's a good start, nobody contribute Redis source, hope you make it. Best, Kang On Wed, Sep 7, 2022 at 5:46 AM Pramod Immaneni wrote: > Hi, > > I wanted to contribute a Redis subscriber source. Not sure if this is the > right JIRA but have asked it to be assigned to me. > > >

[jira] [Created] (FLINK-29215) Use config based constructors for flink calcite Converter rules

2022-09-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29215: --- Summary: Use config based constructors for flink calcite Converter rules Key: FLINK-29215 URL: https://issues.apache.org/jira/browse/FLINK-29215 Project: Flink

redis subscriber source

2022-09-06 Thread Pramod Immaneni
Hi, I wanted to contribute a Redis subscriber source. Not sure if this is the right JIRA but have asked it to be assigned to me. https://issues.apache.org/jira/browse/FLINK-3033 Thanks, Pramod

[jira] [Created] (FLINK-29214) Remove usages of deprecated agg.indicator

2022-09-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29214: --- Summary: Remove usages of deprecated agg.indicator Key: FLINK-29214 URL: https://issues.apache.org/jira/browse/FLINK-29214 Project: Flink Issue Type:

[DISCUSS] Re: Energy/performance research questions

2022-09-06 Thread Sharma, Sanskriti, Rakesh
Hi Piotr, Thank you so much for responding. We will look into those benchmarks. Something our group is considering is how the OS network stack affects a distributed application like Flink. Thank you! Sana From: Piotr Nowojski Sent: Friday, August 26, 2022

[jira] [Created] (FLINK-29213) Pretty schema json file

2022-09-06 Thread MOBIN (Jira)
MOBIN created FLINK-29213: - Summary: Pretty schema json file Key: FLINK-29213 URL: https://issues.apache.org/jira/browse/FLINK-29213 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-29212) Properly load Hadoop native libraries in Flink docker iamges

2022-09-06 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-29212: -- Summary: Properly load Hadoop native libraries in Flink docker iamges Key: FLINK-29212 URL: https://issues.apache.org/jira/browse/FLINK-29212 Project: Flink

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Jingsong Li
+1 On Tue, Sep 6, 2022 at 7:11 PM Yu Li wrote: > > +1 > > Thanks for the efforts, Chesnay > > Best Regards, > Yu > > > On Tue, 6 Sept 2022 at 18:17, Martijn Visser > wrote: > > > +1 (binding) > > > > Op di 6 sep. 2022 om 11:59 schreef Xingbo Huang : > > > > > Thanks Chesnay for driving this, >

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Yu Li
+1 Thanks for the efforts, Chesnay Best Regards, Yu On Tue, 6 Sept 2022 at 18:17, Martijn Visser wrote: > +1 (binding) > > Op di 6 sep. 2022 om 11:59 schreef Xingbo Huang : > > > Thanks Chesnay for driving this, > > > > +1 > > > > Best, > > Xingbo > > > > Xintong Song 于2022年9月6日周二 17:57写道：

[jira] [Created] (FLINK-29211) Hive 2.3.9 NOTICE is incorrect

2022-09-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29211: Summary: Hive 2.3.9 NOTICE is incorrect Key: FLINK-29211 URL: https://issues.apache.org/jira/browse/FLINK-29211 Project: Flink Issue Type: Technical

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Martijn Visser
+1 (binding) Op di 6 sep. 2022 om 11:59 schreef Xingbo Huang : > Thanks Chesnay for driving this, > > +1 > > Best, > Xingbo > > Xintong Song 于2022年9月6日周二 17:57写道： > > > +1 > > > > Best, > > > > Xintong > > > > > > > > On Tue, Sep 6, 2022 at 5:55 PM Konstantin Knauf > wrote: > > > > > +1.

[jira] [Created] (FLINK-29210) Documented SQL Client setup when using Docker Compose doesn't work

2022-09-06 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29210: -- Summary: Documented SQL Client setup when using Docker Compose doesn't work Key: FLINK-29210 URL: https://issues.apache.org/jira/browse/FLINK-29210 Project:

[jira] [Created] (FLINK-29209) Fail to connect HiveServer endpoint with TProtocolException

2022-09-06 Thread luoyuxia (Jira)
luoyuxia created FLINK-29209: Summary: Fail to connect HiveServer endpoint with TProtocolException Key: FLINK-29209 URL: https://issues.apache.org/jira/browse/FLINK-29209 Project: Flink Issue

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Xingbo Huang
Thanks Chesnay for driving this, +1 Best, Xingbo Xintong Song 于2022年9月6日周二 17:57写道： > +1 > > Best, > > Xintong > > > > On Tue, Sep 6, 2022 at 5:55 PM Konstantin Knauf wrote: > > > +1. Thanks, Chesnay. > > > > Am Di., 6. Sept. 2022 um 11:51 Uhr schrieb Chesnay Schepler < > >

Re: [DISCUSS] Releasing Flink 1.14.6

2022-09-06 Thread Xintong Song
+1 Best, Xintong On Tue, Sep 6, 2022 at 5:55 PM Konstantin Knauf wrote: > Sounds good. +1. > > Am Di., 6. Sept. 2022 um 10:45 Uhr schrieb Jingsong Li < > jingsongl...@gmail.com>: > > > +1 for 1.14.6 > > > > Thanks Xingbo for driving. > > > > Best, > > Jingsong > > > > On Tue, Sep 6, 2022 at

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Xintong Song
+1 Best, Xintong On Tue, Sep 6, 2022 at 5:55 PM Konstantin Knauf wrote: > +1. Thanks, Chesnay. > > Am Di., 6. Sept. 2022 um 11:51 Uhr schrieb Chesnay Schepler < > ches...@apache.org>: > > > Since no one objected in the discuss thread, let's vote! > > > > FLIP: > > >

Re: [DISCUSS] Releasing Flink 1.14.6

2022-09-06 Thread Konstantin Knauf
Sounds good. +1. Am Di., 6. Sept. 2022 um 10:45 Uhr schrieb Jingsong Li < jingsongl...@gmail.com>: > +1 for 1.14.6 > > Thanks Xingbo for driving. > > Best, > Jingsong > > On Tue, Sep 6, 2022 at 4:42 PM Xingbo Huang wrote: > > > > Hi all, > > > > I would like to start discussing releasing Flink

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Konstantin Knauf
+1. Thanks, Chesnay. Am Di., 6. Sept. 2022 um 11:51 Uhr schrieb Chesnay Schepler < ches...@apache.org>: > Since no one objected in the discuss thread, let's vote! > > FLIP: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152857 > > The vote will be open for at least 72h. >

[VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

2022-09-06 Thread Chesnay Schepler
Since no one objected in the discuss thread, let's vote! FLIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=225152857 The vote will be open for at least 72h. Regards, Chesnay

[jira] [Created] (FLINK-29208) Logs and stdout endpoints not mentioned on OpenAPI spec

2022-09-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29208: --- Summary: Logs and stdout endpoints not mentioned on OpenAPI spec Key: FLINK-29208 URL: https://issues.apache.org/jira/browse/FLINK-29208 Project: Flink Issue

[jira] [Created] (FLINK-29207) Pulsar message eventTime may be incorrectly set to a negative number

2022-09-06 Thread Wenbing Shen (Jira)
Wenbing Shen created FLINK-29207: Summary: Pulsar message eventTime may be incorrectly set to a negative number Key: FLINK-29207 URL: https://issues.apache.org/jira/browse/FLINK-29207 Project: Flink

[jira] [Created] (FLINK-29206) Default Flink configuration contains irrelevant settings

2022-09-06 Thread Arseniy Tashoyan (Jira)
Arseniy Tashoyan created FLINK-29206: Summary: Default Flink configuration contains irrelevant settings Key: FLINK-29206 URL: https://issues.apache.org/jira/browse/FLINK-29206 Project: Flink

Re: [DISCUSS] Releasing Flink 1.14.6

2022-09-06 Thread Jingsong Li
+1 for 1.14.6 Thanks Xingbo for driving. Best, Jingsong On Tue, Sep 6, 2022 at 4:42 PM Xingbo Huang wrote: > > Hi all, > > I would like to start discussing releasing Flink 1.14.6. > > It has already been almost three months since we released 1.14.5. There are > currently 35 tickets[1] and 33

[DISCUSS] Releasing Flink 1.14.6

2022-09-06 Thread Xingbo Huang
Hi all, I would like to start discussing releasing Flink 1.14.6. It has already been almost three months since we released 1.14.5. There are currently 35 tickets[1] and 33 commits[2] already resolved for 1.14.6, some of them quite important, such as FLINK-27399

Re: Flink Kinesis Connector EFO not working for cross-accounts

2022-09-06 Thread Danny Cranmer
Jira https://issues.apache.org/jira/browse/FLINK-29205 On Tue, Sep 6, 2022 at 9:33 AM Danny Cranmer wrote: > Hello Iris, > > I have been looking into this and can confirm there is a bug. It is > expected that this should work, but it looks like it was broken in Flink > 1.15. I will follow up

[jira] [Created] (FLINK-29205) FlinkKinesisConsumer not respecting Credential Provider configuration for EFO

2022-09-06 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-29205: - Summary: FlinkKinesisConsumer not respecting Credential Provider configuration for EFO Key: FLINK-29205 URL: https://issues.apache.org/jira/browse/FLINK-29205

Re: Flink Kinesis Connector EFO not working for cross-accounts

2022-09-06 Thread Danny Cranmer
Hello Iris, I have been looking into this and can confirm there is a bug. It is expected that this should work, but it looks like it was broken in Flink 1.15. I will follow up with a Jira and a fix. Thanks for reporting this. Danny

[SUMMARY] Flink 1.16 release sync of 2022-09-06

2022-09-06 Thread Xingbo Huang
I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-09-06. *We have cut release-1.16 branch yesterday(5th of September 2022). It is expected that we will prepare rc0 for further testing in a few days* *We're almost done with x-team testing[1]. The remaining

[jira] [Created] (FLINK-29204) JoinITCase#testUncorrelatedScalar fails with Cannot generate a valid execution plan for the given query after calcite update 1.27

2022-09-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29204: --- Summary: JoinITCase#testUncorrelatedScalar fails with Cannot generate a valid execution plan for the given query after calcite update 1.27 Key: FLINK-29204 URL:

[jira] [Created] (FLINK-29203) SetOperatorsITCase#testUnionAllWithCommonType is failing after Calcite update to 1.27

2022-09-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29203: --- Summary: SetOperatorsITCase#testUnionAllWithCommonType is failing after Calcite update to 1.27 Key: FLINK-29203 URL: https://issues.apache.org/jira/browse/FLINK-29203

[jira] [Created] (FLINK-29202) CliClient fails with NPE during start (after calcite update to 1.27)

2022-09-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29202: --- Summary: CliClient fails with NPE during start (after calcite update to 1.27) Key: FLINK-29202 URL: https://issues.apache.org/jira/browse/FLINK-29202 Project: