答复: [DISCUSS] Release 2.0 Work Items

2023-07-12 Thread li zhiqiang
@Xingtong I already know the modification of some api, but because there are many changes involved, I am afraid that the consideration is not comprehensive. I'm willing to do the work, but I haven't found a committer yet. Best, Zhiqiang 发件人: Xintong Song 日期: 星期四, 2023年7月13日 10:03 收件人:

Re: [DISCUSS] Release 2.0 Work Items

2023-07-12 Thread Xintong Song
Thanks for the inputs, Zhiqiang and Jiabao. @Zhiqiang, The proposal sounds interesting. Do you already have an idea what API changes are needed in order to make the connectors pluggable? I think whether this should go into Flink 2.0 would significantly depend on what API changes are needed.

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

2023-07-12 Thread Jing Ge
Hi Yunfeng, Thanks for the proposal. It makes sense to offer the optimization. I got some NIT questions. 1. I guess you changed your thoughts while coding the POC, I found pipeline.enable-operator-timestamp in the code but is pipeline.force-timestamp-support defined in the FLIP 2. about the

Re: [DISCUSS] FLIP 333 - Redesign Apache Flink website

2023-07-12 Thread Danny Cranmer
Thanks for driving this Deepthi. Looks great to me; a huge improvement over the current website. We had agreed in the previous discussion [1] to keep the main website separate from the docs since the target audience is different. I am inclined to decouple the two and re-evaluate updating the docs

Re: [DISCUSS] Release 2.0 Work Items

2023-07-12 Thread Jiabao Sun
Thanks Xintong for driving the effort. I’d add a +1 to improving out-of-box user experience, as suggested by @Jark and @Chesnay. For beginners, understanding complex configurations is a hard work. In addition, the deployment of a set of Flink runtime environment is also a complex matter. At

[jira] [Created] (FLINK-32585) Filter javax.xml.bind:jaxb-api false positive for Pulsar connector

2023-07-12 Thread Zili Chen (Jira)
Zili Chen created FLINK-32585: - Summary: Filter javax.xml.bind:jaxb-api false positive for Pulsar connector Key: FLINK-32585 URL: https://issues.apache.org/jira/browse/FLINK-32585 Project: Flink

Re: [VOTE] FLIP-322 Cooldown period for adaptive scheduler. Second vote.

2023-07-12 Thread Etienne Chauchot
Hi all, I'm going on vacation tonight for 3 weeks. Even if the vote is not finished, as the implementation is rather quick and the design discussion had settled, I preferred I implementing FLIP-322 [1] to allow people to take a look while I'm off. [1]

[jira] [Created] (FLINK-32584) Make it possible to unset default catalog and/or database

2023-07-12 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-32584: Summary: Make it possible to unset default catalog and/or database Key: FLINK-32584 URL: https://issues.apache.org/jira/browse/FLINK-32584 Project: Flink

Re: [DISCUSS] Release 2.0 Work Items

2023-07-12 Thread zhiqiang li
I have seen in [1] connectors and formats, and user code will be pluggable. If the connectors are pluggable, the benefits are obvious, as the conflicts between different jar package versions can be avoided. If you don't use classloader isolation, shade is needed to resolve conflicts. A lot of

[jira] [Created] (FLINK-32583) RestClient can deadlock if request made after Netty event executor terminated

2023-07-12 Thread Patrick Lucas (Jira)
Patrick Lucas created FLINK-32583: - Summary: RestClient can deadlock if request made after Netty event executor terminated Key: FLINK-32583 URL: https://issues.apache.org/jira/browse/FLINK-32583

Re: [DISCUSS] FLIP-327: Support stream-batch unified operator to improve job throughput when processing backlog data

2023-07-12 Thread Jing Ge
Hi Dong, Thanks for your reply! Best regards, Jing On Wed, Jul 12, 2023 at 3:25 AM Dong Lin wrote: > Hi Jing, > > Thanks for the comments. Please see my reply inline. > > On Wed, Jul 12, 2023 at 5:04 AM Jing Ge > wrote: > > > Hi Dong, > > > > Thanks for the clarification. Now it is clear for

Re: [VOTE] FLIP-322 Cooldown period for adaptive scheduler. Second vote.

2023-07-12 Thread Etienne Chauchot
Hi all, Would you mind casting your vote to this second vote thread (opened after new discussions) so that the subject can move forward ? @David, @Chesnay, @Robert you took part to the discussions, can you please sent your vote ? Thank you very much Best Etienne Le 06/07/2023 à 13:02,

[jira] [Created] (FLINK-32582) Move TypeSerializerUpgradeTestBase from Kafka connector into flink-connector-common

2023-07-12 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32582: - Summary: Move TypeSerializerUpgradeTestBase from Kafka connector into flink-connector-common Key: FLINK-32582 URL: https://issues.apache.org/jira/browse/FLINK-32582

Re: [VOTE] Release 2.0 must-have work items

2023-07-12 Thread yuxia
Thanks Xintong for clarification. A guideline to help users migrating from DataSet to DataStream will definitely be helpful. Best regards, Yuxia - 原始邮件 - 发件人: "Xintong Song" 收件人: "dev" 发送时间: 星期三, 2023年 7 月 12日 上午 11:40:12 主题: Re: [VOTE] Release 2.0 must-have work items @Yuxia, We