[jira] [Created] (FLINK-29227) shoud package disruptor(com.lmax) to flink lib for aync logger when xxconnector using it.

2022-09-07 Thread jackylau (Jira)
jackylau created FLINK-29227: Summary: shoud package disruptor(com.lmax) to flink lib for aync logger when xxconnector using it. Key: FLINK-29227 URL: https://issues.apache.org/jira/browse/FLINK-29227 Pro

Code Review Request

2022-09-07 Thread ganlute
Could anyone help me review the changes?Thank you~ Here is the JIRA: https://issues.apache.org/jira/browse/FLINK-28910 Here is the PR: https://github.com/apache/flink/pull/20542

Re: [DISCUSS] Releasing Flink 1.14.6

2022-09-07 Thread Yu Li
+1 Best Regards, Yu On Tue, 6 Sept 2022 at 17:57, Xintong Song wrote: > +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

[jira] [Created] (FLINK-29226) Throw exception for streaming insert overwrite

2022-09-07 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29226: Summary: Throw exception for streaming insert overwrite Key: FLINK-29226 URL: https://issues.apache.org/jira/browse/FLINK-29226 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-29225) Delete message incorrectly ignored in SinkUpsertMaterializer

2022-09-07 Thread lincoln lee (Jira)
lincoln lee created FLINK-29225: --- Summary: Delete message incorrectly ignored in SinkUpsertMaterializer Key: FLINK-29225 URL: https://issues.apache.org/jira/browse/FLINK-29225 Project: Flink I

[jira] [Created] (FLINK-29224) flink-mirror does not pick up the new release branch 1.16

2022-09-07 Thread Jing Ge (Jira)
Jing Ge created FLINK-29224: --- Summary: flink-mirror does not pick up the new release branch 1.16 Key: FLINK-29224 URL: https://issues.apache.org/jira/browse/FLINK-29224 Project: Flink Issue Type: B

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

2022-09-07 Thread Thomas Weise
+1 On Wed, Sep 7, 2022 at 4:48 AM Danny Cranmer wrote: > +1 > > On Wed, 7 Sept 2022, 07:32 Zhu Zhu, wrote: > > > +1 > > > > Thanks, > > Zhu > > > > Jingsong Li 于2022年9月6日周二 19:49写道: > > > > > > +1 > > > > > > On Tue, Sep 6, 2022 at 7:11 PM Yu Li wrote: > > > > > > > > +1 > > > > > > > > Than

[jira] [Created] (FLINK-29223) Missing debug output for when filtering JobGraphs based on their persisted JobResult

2022-09-07 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29223: - Summary: Missing debug output for when filtering JobGraphs based on their persisted JobResult Key: FLINK-29223 URL: https://issues.apache.org/jira/browse/FLINK-29223

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

2022-09-07 Thread Etienne Chauchot
Oops, I missed this thread: https://lists.apache.org/thread/l57yqr1jpwjmtb4ldrnlww79lcmdod1n closing this one. Etienne Le 07/09/2022 à 15:03, Etienne Chauchot a écrit : Hi all, I'd like to share a concerning news. I've just read that Akka will move from ASFv2 license to BSLv1.1 (1) I gues

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

2022-09-07 Thread Chesnay Schepler
But fair enough, different target audiences. For the time being we don't have to do anything. We'll just stay on 2.6.x and see how things unfold. We don't really care about new Akka features after all. If a fork pops up we could switch to that, otherwise we can look into alternative libraries

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

2022-09-07 Thread Chesnay Schepler
This is already being discussed on the user ML. See "New licensing for Akka" On 07/09/2022 15:03, Etienne Chauchot wrote: Hi all, I'd like to share a concerning news. I've just read that Akka will move from ASFv2 license to BSLv1.1 (1) I guess this license is considered Category X (2) by th

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

2022-09-07 Thread Etienne Chauchot
I just came by this ticket on LEGAL that Chesnay opened: https://issues.apache.org/jira/browse/LEGAL-619 Best Etienne Le 07/09/2022 à 15:03, Etienne Chauchot a écrit : Hi all, I'd like to share a concerning news. I've just read that Akka will move from ASFv2 license to BSLv1.1 (1) I guess

[NEWS][DISCUSS] Akka moves to BSL licence

2022-09-07 Thread Etienne Chauchot
Hi all, I'd like to share a concerning news. I've just read that Akka will move from ASFv2 license to BSLv1.1 (1) I guess this license is considered Category X (2) by the ASF and cannot be included in ASF projects. Let's discuss possible solutions. Best Etienne [1] https://www.lightbend.

[jira] [Created] (FLINK-29222) Wrong behavior for Hive's load data inpath

2022-09-07 Thread luoyuxia (Jira)
luoyuxia created FLINK-29222: Summary: Wrong behavior for Hive's load data inpath Key: FLINK-29222 URL: https://issues.apache.org/jira/browse/FLINK-29222 Project: Flink Issue Type: Bug

Re: Migrating Sink v1 to v2

2022-09-07 Thread Krzysztof Chmielewski
A small update, When I change number of Sinks from 3 to 1, test passes. śr., 7 wrz 2022 o 12:18 Krzysztof Chmielewski < krzysiek.chmielew...@gmail.com> napisał(a): > Hi, > I'm a co-author for opensource Delta-Flink connector hosted on [1]. > The connector was originated for Flink 1.12 and current

Migrating Sink v1 to v2

2022-09-07 Thread Krzysztof Chmielewski
Hi, I'm a co-author for opensource Delta-Flink connector hosted on [1]. The connector was originated for Flink 1.12 and currently we migrated to 1.14. Both sink and source are using new Unified API from Flink 1.12. I'm evaluating migration to Flink 1.15 where Sink v1 was marked as deprecated. Afte

[jira] [Created] (FLINK-29221) Adding join hint in sql may cause imcompatible state

2022-09-07 Thread xuyang (Jira)
xuyang created FLINK-29221: -- Summary: Adding join hint in sql may cause imcompatible state Key: FLINK-29221 URL: https://issues.apache.org/jira/browse/FLINK-29221 Project: Flink Issue Type: Improvem

Re: Sink V2 interface replacement for GlobalCommitter

2022-09-07 Thread Yun Gao
Hi Steven, Liwei, Very sorry for missing this mail and response very late. I think the initial thought is indeed to use `WithPostCommitTopology` as a replacement of the original GlobalCommitter, and currently the adapter of Sink v1 on top of Sink v2 also maps the GlobalCommitter in Sink V1 interf

[jira] [Created] (FLINK-29220) Skip ci tests on docs-only-PRs

2022-09-07 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-29220: Summary: Skip ci tests on docs-only-PRs Key: FLINK-29220 URL: https://issues.apache.org/jira/browse/FLINK-29220 Project: Flink Issue Type: Improvement

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

2022-09-07 Thread Danny Cranmer
+1 On Wed, 7 Sept 2022, 07:32 Zhu Zhu, wrote: > +1 > > Thanks, > Zhu > > Jingsong Li 于2022年9月6日周二 19:49写道: > > > > +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 Se

Re: [DISCUSS] Re: Energy/performance research questions

2022-09-07 Thread Piotr Nowojski
Hi Sana, > Something our group is considering is how the OS network stack affects a distributed application like Flink. To the best of my knowledge, in a healthy cluster, such low level overheads are very rarely a problem for Flink. There are much more prominent overheads in other places. First a

[jira] [Created] (FLINK-29219) CREATE TABLE AS statement blocks SQL client's execution

2022-09-07 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-29219: - Summary: CREATE TABLE AS statement blocks SQL client's execution Key: FLINK-29219 URL: https://issues.apache.org/jira/browse/FLINK-29219 Project: Flink Iss

[jira] [Created] (FLINK-29218) ADD JAR syntax could not work with Hive catalog in SQL client

2022-09-07 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-29218: - Summary: ADD JAR syntax could not work with Hive catalog in SQL client Key: FLINK-29218 URL: https://issues.apache.org/jira/browse/FLINK-29218 Project: Flink