[jira] [Created] (FLINK-29277) Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented'

2022-09-12 Thread Jiankun Feng (Jira)
Jiankun Feng created FLINK-29277: Summary: Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented' Key: FLINK-29277 URL: https://

Re: [VOTE] FLIP-254 Redis Streams connector

2022-09-12 Thread Yu Li
Hi Martijn, Thanks for driving this forward, but from the discussion thread [1], it seems one question from Konstantin is still not answered: does this FLIP only aim to add source/sink connectors for Redis Streams, and we will create another one to support regular Redis data structures (as LookupT

[jira] [Created] (FLINK-29276) Flush all memory in SortBufferMemTable.clear

2022-09-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29276: Summary: Flush all memory in SortBufferMemTable.clear Key: FLINK-29276 URL: https://issues.apache.org/jira/browse/FLINK-29276 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-29275) Temporal Table function: Cannot add expression of different type to set

2022-09-12 Thread Tally (Jira)
Tally created FLINK-29275: - Summary: Temporal Table function: Cannot add expression of different type to set Key: FLINK-29275 URL: https://issues.apache.org/jira/browse/FLINK-29275 Project: Flink Is

[jira] [Created] (FLINK-29274) HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed

2022-09-12 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-29274: Summary: HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed Key: FLINK-29274 URL: https://issues.apache.org/jira/browse/FLINK-292

[jira] [Created] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29273: Summary: Page not enough Exception in SortBufferMemTable Key: FLINK-29273 URL: https://issues.apache.org/jira/browse/FLINK-29273 Project: Flink Issue Type: B

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Qingsheng Ren
Congratulations Martijn! Best regards, Qingsheng > On Sep 9, 2022, at 23:08, Timo Walther wrote: > > Hi everyone, > > I'm very happy to announce that Martijn Visser has joined the Flink PMC! > > Martijn has helped the community in many different ways over the past months. > Externalizing t

[jira] [Created] (FLINK-29272) Document DataStream API (DataStream to Table) for table store

2022-09-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29272: Summary: Document DataStream API (DataStream to Table) for table store Key: FLINK-29272 URL: https://issues.apache.org/jira/browse/FLINK-29272 Project: Flink

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Paul Lam
Congrats, Martijn! Well deserved! Best, Paul Lam > 2022年9月13日 10:53,Jingsong Li 写道: > > Congrats, Martijn! > > Best, > Jingsong > > On Tue, Sep 13, 2022 at 10:48 AM Yang Wang wrote: >> >> Congrats, Martijn! >> >> Best, >> Yang >> >> Lijie Wang 于2022年9月13日周二 10:10写道: >> >>> Congratulatio

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Jingsong Li
Congrats, Martijn! Best, Jingsong On Tue, Sep 13, 2022 at 10:48 AM Yang Wang wrote: > > Congrats, Martijn! > > Best, > Yang > > Lijie Wang 于2022年9月13日周二 10:10写道: > > > Congratulations, Martijn! > > > > Best, > > Lijie > > > > yuxia 于2022年9月13日周二 09:52写道: > > > > > Congrats, Martijn! > > > > >

[jira] [Created] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
jiangjiguang0719 created FLINK-29271: Summary: Change to byte array from bytebuffer to improve performance when reading parquet file Key: FLINK-29271 URL: https://issues.apache.org/jira/browse/FLINK-29271

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Yang Wang
Congrats, Martijn! Best, Yang Lijie Wang 于2022年9月13日周二 10:10写道: > Congratulations, Martijn! > > Best, > Lijie > > yuxia 于2022年9月13日周二 09:52写道: > > > Congrats, Martijn! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Steven Wu" > > 收件人: "dev" > > 发送时间: 星期二, 2022年 9 月 13日 上午

[jira] [Created] (FLINK-29270) Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE

2022-09-12 Thread Muhammad Hilmi Al Fatih (Jira)
Muhammad Hilmi Al Fatih created FLINK-29270: --- Summary: Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE Key: FLINK-29270 URL: https://issues.apache.org/jira/browse/FLINK-29270

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Lijie Wang
Congratulations, Martijn! Best, Lijie yuxia 于2022年9月13日周二 09:52写道: > Congrats, Martijn! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Steven Wu" > 收件人: "dev" > 发送时间: 星期二, 2022年 9 月 13日 上午 5:33:47 > 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser > > Congrats, Martijn!

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread yuxia
Congrats, Martijn! Best regards, Yuxia - 原始邮件 - 发件人: "Steven Wu" 收件人: "dev" 发送时间: 星期二, 2022年 9 月 13日 上午 5:33:47 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser Congrats, Martijn! On Mon, Sep 12, 2022 at 1:49 PM Alexander Fedulov wrote: > Congrats, Martijn! > > On Mon

Re: Recommended way to Enable SSL Flink Kubernetes Operator

2022-09-12 Thread Hao t Chang
Hi Biao I think this modify basic-example FlinkDeployment should load the existing keystore although I am not certain re-using the webhook keystore recommended. apiVersion: flink.apache.org/v1beta1 kind: FlinkDeployment metadata: name: basic-example spec: image: flink:1.15 flinkVersion: v1

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Steven Wu
Congrats, Martijn! On Mon, Sep 12, 2022 at 1:49 PM Alexander Fedulov wrote: > Congrats, Martijn! > > On Mon, Sep 12, 2022 at 10:06 AM Jing Ge wrote: > > > Congrats! > > > > On Mon, Sep 12, 2022 at 9:38 AM Daisy Tsang wrote: > > > > > Congrats! > > > > > > On Mon, Sep 12, 2022 at 9:32 AM Martij

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Alexander Fedulov
Congrats, Martijn! On Mon, Sep 12, 2022 at 10:06 AM Jing Ge wrote: > Congrats! > > On Mon, Sep 12, 2022 at 9:38 AM Daisy Tsang wrote: > > > Congrats! > > > > On Mon, Sep 12, 2022 at 9:32 AM Martijn Visser > > > wrote: > > > > > Thank you all :) > > > > > > Op zo 11 sep. 2022 om 13:58 schreef Z

[jira] [Created] (FLINK-29269) Setup CI logging

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29269: Summary: Setup CI logging Key: FLINK-29269 URL: https://issues.apache.org/jira/browse/FLINK-29269 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-29268) Sync 1.16.0 code to ES repo

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29268: Summary: Sync 1.16.0 code to ES repo Key: FLINK-29268 URL: https://issues.apache.org/jira/browse/FLINK-29268 Project: Flink Issue Type: Sub-task

Re: HELP: New repository 'flink-connector-opensearch' under ASF organization

2022-09-12 Thread Andrey Redko
Thank you very much, Chesnay! Best Regards, Andriy Redko On Mon, Sep 12, 2022, 2:01 PM Chesnay Schepler wrote: > - created repo https://github.com/apache/flink-connector-opensearch > - Conectors/Opensearch component added to JIRA > - opensearch-1.0.0 version added to JIRA > > On 02/09/2022

Re: HELP: New repository 'flink-connector-opensearch' under ASF organization

2022-09-12 Thread Chesnay Schepler
- created repo https://github.com/apache/flink-connector-opensearch - Conectors/Opensearch component added to JIRA - opensearch-1.0.0 version added to JIRA On 02/09/2022 19:43, Andriy Redko wrote: Hello Everyone, Kindly asking PMCs for help with creating new 'flink-connector-opensearch' reposi

[jira] [Created] (FLINK-29267) Support external type systems in DDL

2022-09-12 Thread Timo Walther (Jira)
Timo Walther created FLINK-29267: Summary: Support external type systems in DDL Key: FLINK-29267 URL: https://issues.apache.org/jira/browse/FLINK-29267 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29266) Cleanup ES root pom

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29266: Summary: Cleanup ES root pom Key: FLINK-29266 URL: https://issues.apache.org/jira/browse/FLINK-29266 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-29265) Update ES version to 3.0-SNAPSHOT

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29265: Summary: Update ES version to 3.0-SNAPSHOT Key: FLINK-29265 URL: https://issues.apache.org/jira/browse/FLINK-29265 Project: Flink Issue Type: Technic

[jira] [Created] (FLINK-29264) Give ES parent module a proper artifact ID

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29264: Summary: Give ES parent module a proper artifact ID Key: FLINK-29264 URL: https://issues.apache.org/jira/browse/FLINK-29264 Project: Flink Issue Type

Re: [VOTE] FLIP-254 Redis Streams connector

2022-09-12 Thread Ryan Skraba
Hello! There's quite a bit of existing code and it looks like there's interest and community willing to contribute to this connector with 2 implementations already in the flink-connector-redis repo[1]. There's a couple of points that should probably be fixed in the FLIP: some typos such as "provi

[jira] [Created] (FLINK-29263) Remove ElasticSearch connector from apache/flink repo

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29263: Summary: Remove ElasticSearch connector from apache/flink repo Key: FLINK-29263 URL: https://issues.apache.org/jira/browse/FLINK-29263 Project: Flink

[jira] [Created] (FLINK-29262) Update documentation

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29262: Summary: Update documentation Key: FLINK-29262 URL: https://issues.apache.org/jira/browse/FLINK-29262 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-29261) Consider using FAIL_ON_UNKNOWN_PROPERTIES in the Operator

2022-09-12 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-29261: - Summary: Consider using FAIL_ON_UNKNOWN_PROPERTIES in the Operator Key: FLINK-29261 URL: https://issues.apache.org/jira/browse/FLINK-29261 Project: Flink I

[jira] [Created] (FLINK-29260) Auto-wipe exclusion list after updating reference version

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29260: Summary: Auto-wipe exclusion list after updating reference version Key: FLINK-29260 URL: https://issues.apache.org/jira/browse/FLINK-29260 Project: Flink

[jira] [Created] (FLINK-29259) Update release guide

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29259: Summary: Update release guide Key: FLINK-29259 URL: https://issues.apache.org/jira/browse/FLINK-29259 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29258) Add SAVEPOINT_ONLY upgrade mode

2022-09-12 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-29258: -- Summary: Add SAVEPOINT_ONLY upgrade mode Key: FLINK-29258 URL: https://issues.apache.org/jira/browse/FLINK-29258 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-29257) Kubernetes operator docs are vague about upgrade mode

2022-09-12 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-29257: -- Summary: Kubernetes operator docs are vague about upgrade mode Key: FLINK-29257 URL: https://issues.apache.org/jira/browse/FLINK-29257 Project: Flink

[jira] [Created] (FLINK-29256) Docs for k8s operator webhook

2022-09-12 Thread Jira
Márton Balassi created FLINK-29256: -- Summary: Docs for k8s operator webhook Key: FLINK-29256 URL: https://issues.apache.org/jira/browse/FLINK-29256 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29255) FLIP-258 - Enforce binary compatibility in patch releases

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29255: Summary: FLIP-258 - Enforce binary compatibility in patch releases Key: FLINK-29255 URL: https://issues.apache.org/jira/browse/FLINK-29255 Project: Flink

[jira] [Created] (FLINK-29254) RpcGateway should have some form of Close() method

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29254: Summary: RpcGateway should have some form of Close() method Key: FLINK-29254 URL: https://issues.apache.org/jira/browse/FLINK-29254 Project: Flink Is

Re: [VOTE] FLIP-254 Redis Streams connector

2022-09-12 Thread Zheng Yu Chen
+1 (non-binding) Martijn Visser 于2022年9月12日周一 15:58写道: > Hi everyone, > > With no comments provided in the discussion thread, I'm opening a vote > thread on FLIP-254: Redis Streams connector: > > FLIP: > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-254%3A+Redis+Streams+Connector > >

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

2022-09-12 Thread Chesnay Schepler
The voting period has elapsed and we have unanimously accepted the FLIP. +1 votes: * Konstantin (binding) * Xintong (binding) * Xinbgo (binding) * Martijn (binding) * Yu (binding) * Jingsong (binding) * Zhu (binding) * Danny (binding) * Thomas (binding) * Alexander (non-binding) On 08/09/2022 2

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Jing Ge
Congrats! On Mon, Sep 12, 2022 at 9:38 AM Daisy Tsang wrote: > Congrats! > > On Mon, Sep 12, 2022 at 9:32 AM Martijn Visser > wrote: > > > Thank you all :) > > > > Op zo 11 sep. 2022 om 13:58 schreef Zheng Yu Chen : > > > > > Congratulations, Martijn > > > > > > > > > > > > Timo Walther 于2022年

Re: [NEWS][DISCUSS] Akka moves to BSL licence

2022-09-12 Thread Etienne Chauchot
Hi, Thanks Chesnay for this clarifying blog post. I was off on Friday, it was merged while I was gone but LGTM. Best Etienne Le 08/09/2022 à 12:25, Chesnay Schepler a écrit : I have prepared a blogpost for the whole situation: https://github.com/apache/flink-web/pull/570 Any feedback/comme

[VOTE] FLIP-254 Redis Streams connector

2022-09-12 Thread Martijn Visser
Hi everyone, With no comments provided in the discussion thread, I'm opening a vote thread on FLIP-254: Redis Streams connector: FLIP: https://cwiki.apache.org/confluence/display/FLINK/FLIP-254%3A+Redis+Streams+Connector The vote will be open for at least 72h. Best regards, Martijn https://tw

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Daisy Tsang
Congrats! On Mon, Sep 12, 2022 at 9:32 AM Martijn Visser wrote: > Thank you all :) > > Op zo 11 sep. 2022 om 13:58 schreef Zheng Yu Chen : > > > Congratulations, Martijn > > > > > > > > Timo Walther 于2022年9月9日周五 23:08写道: > > > > > Hi everyone, > > > > > > I'm very happy to announce that Martijn

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

2022-09-12 Thread Martijn Visser
Thank you all :) Op zo 11 sep. 2022 om 13:58 schreef Zheng Yu Chen : > Congratulations, Martijn > > > > Timo Walther 于2022年9月9日周五 23:08写道: > > > Hi everyone, > > > > I'm very happy to announce that Martijn Visser has joined the Flink PMC! > > > > Martijn has helped the community in many differen