Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1

+1 (non-binding) - verified signatures - verified hashsums - built from source code with JDK 1.8 succeeded - checked release notes - reviewed the web PR - check the jar is built with JDK 1.8 Best, Hang Leonard Xu 于2024年5月22日周三 21:07写道： > +1 (binding) > > - verified signatures > - verified

Re: [VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1

+1 (non-binding) - verified signatures - verified hashsums - built from source code with JDK 11 succeed - checked release notes - reviewed the web PR Best, Hang Leonard Xu 于2024年5月22日周三 21:02写道： > > > +1 (binding) > > > > - verified signatures > > - verified hashsums > > - built from source

Re: [VOTE] FLIP-457: Improve Table/SQL Configuration for Flink 2.0

+1 (non-binding) Best, Hang gongzhongqiang 于2024年5月27日周一 14:16写道： > +1 (non-binding) > > Best, > Zhongqiang Gong > > Jane Chan 于2024年5月24日周五 09:52写道： > > > Hi all, > > > > I'd like to start a vote on FLIP-457[1] after reaching a consensus > through > > the discussion thread[2]. > > > > The

Re: [DISCUSS] Flink CDC Upgrade Debezium version to 2.x

Hi, zhongqiang. Thanks for this discussion. IMO, I agree to update the references in Flink CDC docs from Debezium 1.9 to 2.0 as the Debezium docs in 1.19 have been dropped. Flink sources in Flink CDC still need to support JDK 1.8. Upgrading Debezium to version 2.x will be a hard job. Have you

Re: [VOTE] Release flink-connector-cassandra v3.2.0, release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Muhammet Orazov 于2024年5月22日周三 04:15写道： > Hey all, > > Could we

Re: [ANNOUNCE] Apache Flink CDC 3.1.0 released

Congratulations! Thanks for the great work. Best, Hang Qingsheng Ren 于2024年5月17日周五 17:33写道： > The Apache Flink community is very happy to announce the release of > Apache Flink CDC 3.1.0. > > Apache Flink CDC is a distributed data integration tool for real time > data and batch data, bringing

Re: [VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction

+1(non-binding) Best, Hang Yuepeng Pan 于2024年5月17日周五 16:15写道： > +1(non-binding) > > > Best, > Yuepeng Pan > > > At 2024-05-15 21:09:04, "Jing Ge" wrote: > >+1(binding) Thanks Martijn! > > > >Best regards, > >Jing > > > >On Wed, May 15, 2024 at 7:00 PM Muhammet Orazov > > wrote: > > > >>

Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #3

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 - Check synchronizing schemas and data from mysql to starrocks following the

Re: flink-connector-kafka weekly CI job failing

] https://issues.apache.org/jira/browse/FLINK-32455 Hang Ruan 于2024年5月11日周六 09:44写道： > Hi, all. > > The class `TypeSerializerMatchers` has been deleted in Flink version > 1.20-SNAPSHOT. > If we need to compile kafka connector with both 1.19 and 1.20, I think we

Re: flink-connector-kafka weekly CI job failing

Hi, all. The class `TypeSerializerMatchers` has been deleted in Flink version 1.20-SNAPSHOT. If we need to compile kafka connector with both 1.19 and 1.20, I think we have to copy `TypeSerializerMatchers` to kafka connector. But it is not a good idea. Besides this, I find that the flink-core

Re: [DISCUSS] Flink CDC 3.2 Release Planning

Thanks Qinsheng for driving. I would like to provide some helps for this verison too. +1. Best, Hang Hongshun Wang 于2024年5月9日周四 14:16写道： > Thanks Qinsheng for driving, > +1 from my side. > > Besi, > Hongshun > > On Wed, May 8, 2024 at 11:41 PM Leonard Xu wrote: > > > +1 for the proposal code

Re: [VOTE] Release flink-connector-kafka v3.2.0, release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Ahmed Hamdy 于2024年4月24日周三 17:21写道： > Thanks Danny, > +1

Re: [VOTE] Release flink-connector-gcp-pubsub v3.1.0, release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Ahmed Hamdy 于2024年4月18日周四 20:01写道： > Hi Danny, > +1 (non-binding) >

Re: [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Ahmed Hamdy 于2024年4月18日周四 21:37写道： > +1 (non-binding) > > -

Re: [VOTE] Release flink-connector-mongodb v1.2.0, release candidate #2

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Ahmed Hamdy 于2024年4月18日周四 21:40写道： > +1 (non-binding) > > -

Re: [VOTE] Release flink-connector-aws v4.3.0, release candidate #2

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Danny Cranmer 于2024年4月19日周五 18:08写道： > Hi everyone, > > Please

Re: [ANNOUNCE] New Apache Flink Committer - Zakelly Lan

Congratulations Zakelly! Best, Hang Yuxin Tan 于2024年4月16日周二 11:04写道： > Congratulations, Zakelly! > > Best, > Yuxin > > > Xuannan Su 于2024年4月16日周二 10:30写道： > > > Congratulations Zakelly! > > > > Best regards, > > Xuannan > > > > On Mon, Apr 15, 2024 at 4:31 PM Jing Ge > > wrote: > > > > > >

Re: [ANNOUNCE] New Apache Flink PMC Member - Jing Ge

Congratulations, Jing! Best, Hang Yuxin Tan 于2024年4月16日周二 11:07写道： > Congratulations, Jing! > > Best, > Yuxin > > > Danny Cranmer 于2024年4月15日周一 20:26写道： > > > Congrats Jing! > > > > Best Regards, > > Danny > > > > On Mon, Apr 15, 2024 at 11:51 AM Swapnal Varma > > wrote: > > > > >

Re: [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee

Congratulations, Lincoln! Best, Hang yh z 于2024年4月16日周二 09:14写道： > Congratulations, Lincoln! > > Best, > Yunhong (Swuferhong) > > > Swapnal Varma 于2024年4月15日周一 18:50写道： > > > Congratulations, Lincoln! > > > > Best, > > Swapnal > > > > > > On Mon, 15 Apr 2024, 15:16 Jacky Lau, wrote: > > > >

Re: [VOTE] FLIP-399: Flink Connector Doris

+1 (non-binding) Best, Hang Martijn Visser 于2024年4月12日周五 05:39写道： > +1 (binding) > > On Wed, Apr 10, 2024 at 4:34 AM Jing Ge > wrote: > > > +1(binding) > > > > Best regards, > > Jing > > > > On Tue, Apr 9, 2024 at 8:54 PM Feng Jin wrote: > > > > > +1 (non-binding) > > > > > > Best, > > >

Re: Re: [ANNOUNCE] Apache Paimon is graduated to Top Level Project

Congratulations! Best, Hang Lincoln Lee 于2024年3月31日周日 00:10写道： > Congratulations! > > Best, > Lincoln Lee > > > Jark Wu 于2024年3月30日周六 22:13写道： > > > Congratulations! > > > > Best, > > Jark > > > > On Fri, 29 Mar 2024 at 12:08, Yun Tang wrote: > > > > > Congratulations to all Paimon guys! > >

Re: [DISCUSS] Flink Website Menu Adjustment

+1 for the proposal. Best, Hang Hangxiang Yu 于2024年3月26日周二 13:40写道： > Thanks Zhongqiang for driving this. > +1 for the proposal. > > On Tue, Mar 26, 2024 at 1:36 PM Shawn Huang wrote: > > > +1 for the proposal > > > > Best, > > Shawn Huang > > > > > > Hongshun Wang 于2024年3月26日周二 11:56写道： > >

Re: [VOTE] FLIP-439: Externalize Kudu Connector from Bahir

+1 (non-binding) Best, Hang Őrhidi Mátyás 于2024年3月21日周四 00:00写道： > +1 (binding) > > On Wed, Mar 20, 2024 at 8:37 AM Gabor Somogyi > wrote: > > > +1 (binding) > > > > G > > > > > > On Wed, Mar 20, 2024 at 3:59 PM Gyula Fóra wrote: > > > > > +1 (binding) > > > > > > Thanks! > > > Gyula > > > >

Re: [ANNOUNCE] Donation Flink CDC into Apache Flink has Completed

- GitHub Repository: https://github.com/apache/flink-cdc >>>> - Flink CDC Documentation: >>>> https://nightlies.apache.org/flink/flink-cdc-docs-stable >>>> >>>> After Flink community accepted this donation[1], we have completed >>>

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

Hi. Yubin. Thanks for your update. LGTM. Best, Hang Yubin Li 于2024年3月20日周三 11:56写道： > Hi Hang, > > I have updated FLIP as you suggested, thanks for your valuable feedback! > > Best, > Yubin > > On Wed, Mar 20, 2024 at 11:15 AM Hang Ruan wrote: > > > >

Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax

+1 (non-binding) Best, Hang Jane Chan 于2024年3月19日周二 22:02写道： > +1 (binding) > > Best, > Jane > > On Tue, Mar 19, 2024 at 9:30 PM Leonard Xu wrote: > > > +1(binding) > > > > > > Best, > > Leonard > > > 2024年3月19日 下午9:03，Lincoln Lee 写道： > > > > > > +1 (binding) > > > > > > Best, > > > Lincoln

Re: Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

> > > > > this > >> > > > > > > > > > FLIP. WDYT? > >> > > > > > > > > > > >> > > > > > > > > > > >> > > > > > > > > > [1] > >> > > > > > > > > > > >

Re: [ANNOUNCE] Apache Flink 1.19.0 released

Congratulations! Best, Hang Paul Lam 于2024年3月18日周一 17:18写道： > Congrats! Thanks to everyone involved! > > Best, > Paul Lam > > > 2024年3月18日 16:37，Samrat Deb 写道： > > > > Congratulations ! > > > > On Mon, 18 Mar 2024 at 2:07 PM, Jingsong Li > wrote: > > > >> Congratulations! > >> > >> On Mon,

Re: [DISCUSS] FLIP-434: Support optimizations for pre-partitioned data sources

Hi, Jeyhun. Thanks for the FLIP. Totally +1 for it. I have a question about the part `Additional option to disable this optimization`. Is this option a source configuration or a table configuration? Besides that, there is a little mistake if I do not understand wrongly. Should `Check if

Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

Hi, Yubin. Thanks for the FLIP. +1 for it. Best, Hang Yubin Li 于2024年3月14日周四 10:15写道： > Hi Jingsong, Feng, and Jeyhun > > Thanks for your support and feedback! > > > However, could we add a new method `getCatalogDescriptor()` to > > CatalogManager instead of directly exposing CatalogStore? >

Re: [VOTE] Release 1.19.0, release candidate #2

+1 (non-binding) - Verified signatures and checksums - Verified that source does not contain binaries - Build source code successfully - Reviewed the release note and left a comment Best, Hang Feng Jin 于2024年3月12日周二 11:23写道： > +1 (non-binding) > > - Verified signatures and checksums > -

Re: [DISCUSS] FLIP Suggestion: Externalize Kudu Connector from Bahir

Hi, Ferenc. Thanks for the FLIP discussion. +1 for the proposal. I think that how to state this code originally lived in Bahir may be in the FLIP. Best, Hang Leonard Xu 于2024年3月7日周四 14:14写道： > Thanks Ferenc for kicking off this discussion, I left some comments here: > > (1) About the release

[jira] [Created] (FLINK-34586) Update the README in Flink CDC

Hang Ruan created FLINK-34586: - Summary: Update the README in Flink CDC Key: FLINK-34586 URL: https://issues.apache.org/jira/browse/FLINK-34586 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

Hang Ruan created FLINK-34585: - Summary: [JUnit5 Migration] Module: Flink CDC Key: FLINK-34585 URL: https://issues.apache.org/jira/browse/FLINK-34585 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34584) Change package name to org.apache.flink.cdc

Hang Ruan created FLINK-34584: - Summary: Change package name to org.apache.flink.cdc Key: FLINK-34584 URL: https://issues.apache.org/jira/browse/FLINK-34584 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-399: Flink Connector Doris

Hi, Thanks for the proposal. +1 for the FLIP. Best, Hang Jeyhun Karimov 于2024年3月2日周六 17:53写道： > Hi, > > Thanks for the proposal. +1 for the FLIP. > I have a few questions: > > - How exactly the two (Stream Load's two-phase commit and Flink's two-phase > commit) combination will ensure the e2e

Re: [VOTE] FLIP-314: Support Customized Job Lineage Listener

+1 (non-binding) Best, Hang weijie guo 于2024年2月29日周四 09:55写道： > +1 (binding) > > Best regards, > > Weijie > > > Feng Jin 于2024年2月29日周四 09:37写道： > > > +1 (non-binding) > > > > Best, > > Feng Jin > > > > On Thu, Feb 29, 2024 at 4:41 AM Márton Balassi > > > wrote: > > > > > +1 (binding) > > > >

Re: Requesting link to join Slack Community

Hi, Geetesh. Here is the invite link : https://join.slack.com/t/apache-flink/shared_invite/zt-1t4khgllz-Fm1CnXzdBbUchBz4HzJCAg . I will raise a PR to update the link. Best, Hang Geetesh Nikhade 于2024年2月28日周三 04:49写道： > Hi Folks, > > I would like to join the Apache Flink Community on Slack,

Re: [VOTE] Release flink-connector-parent 1.1.0 release candidate #2

+1 (non-binding) - verified checksum and signature - checked Github release tag - checked release notes - verified no binaries in source - reviewed the web PR Best, Hang Leonard Xu 于2024年2月20日周二 14:26写道： > +1 (binding) > > - verified signatures > - verified hashsums > - built from source code

Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

Congratulations, Jiabao! Best, Hang Qingsheng Ren 于2024年2月19日周一 17:53写道： > Hi everyone, > > On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink > Committer. > > Jiabao began contributing in August 2022 and has contributed 60+ commits > for Flink main repo and various

Re: 退订

Hi, 请分别发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 和 dev-unsubscr...@flink.apache.org 地址来取消订阅来自 user...@flink.apache.org 和 dev@flink.apache.org 邮件组的邮件，你可以参考[1][2] 管理你的邮件订阅。 Please send email to user-zh-unsubscr...@flink.apache.org and dev-unsubscr...@flink.apache.org if you want to

Re: [VOTE] FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

+1 (non-binding) Best, Hang Dong Lin 于2024年2月5日周一 11:08写道： > Thanks for the FLIP. > > +1 (binding) > > Best, > Dong > > On Wed, Jan 31, 2024 at 11:41 AM Xuannan Su wrote: > > > Hi everyone, > > > > Thanks for all the feedback about the FLIP-331: Support > > EndOfStreamTrigger and

Re: [VOTE] Release flink-connector-jdbc, release candidate #3

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Check that the jar is built by jdk8 Best, Hang Sergey Nuyanzin 于2024年2月1日周四 19:50写道： > Hi everyone, > Please review and vote on the

Re: [VOTE] Release flink-connector-mongodb v1.1.0, release candidate #2

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk11 - Verified web PR - Check that the jar is built by jdk8 - Review the release note Best, Hang Jiabao Sun 于2024年1月30日周二 21:44写道： >

Re: [VOTE] Release flink-connector-mongodb 1.1.0, release candidate #1

Hi, Leonard. I find that META-INF/MANIFEST.MF in flink-sql-connector-mongodb-1.1.0-1.18.jar shows as follow. Manifest-Version: 1.0 Archiver-Version: Plexus Archiver Created-By: Apache Maven 3.8.1 Built-By: bangjiangxu Build-Jdk: 11.0.11 Specification-Title: Flink : Connectors : SQL : MongoDB

Re: [VOTE] Release flink-connector-jdbc, release candidate #2

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk11 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Jiabao Sun 于2024年1月30日周二 10:52写道： > +1(non-binding) > > - Release

Re: [VOTE] Release flink-connector-kafka v3.1.0, release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk11 - Verified web PR - Check that the jar is built by jdk8 Best, Hang Martijn Visser 于2024年1月26日周五 21:05写道： > Hi everyone, > Please

Re: [DISCUSS] Release new version of Flink's Kafka connector

Thanks, Martijn. +1 for releasing a version 3.1 , which only supports Flink 1.18. Best, Hang Leonard Xu 于2024年1月26日周五 16:18写道： > Thanks Martijn for driving this. > > +1 to use v3.1 version/branch, we can use v4.0 for Flink minor versions > 1.18&1.19 later. > > > Best, > Leonard > > > > >

Re: [VOTE] FLIP-417: Expose JobManagerOperatorMetrics via REST API

Thanks for the FLIP. +1 (non-binding) Best, Hang Mason Chen 于2024年1月26日周五 04:51写道： > Hi Devs, > > I would like to start a vote on FLIP-417: Expose JobManagerOperatorMetrics > via REST API [1] which has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless

Re: [DISCUSS] FLIP-417: Expose JobManagerOperatorMetrics via REST API

/flink-docs-master/docs/ops/rest_api/ > [2] > > https://github.com/apache/flink/blob/416cb7aaa02c176e01485ff11ab4269f76b5e9e2/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/jsonplan/JsonPlanGenerator.java#L53 > > Best, > Mason > > > On Thu, Jan 11, 20

Re: [VOTE] FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

+1 (non-binding) Best, Hang Jiabao Sun 于2024年1月9日周二 19:39写道： > Hi Devs, > > I'd like to start a vote on FLIP-377: Support fine-grained configuration > to control filter push down for Table/SQL Sources[1] > which has been discussed in this thread[2]. > > The vote will be open for at least 72

Re: [VOTE] Release flink-connector-rabbitmq, v3.0.2 release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk11 - Verified web PR Best, Hang Jiabao Sun 于2024年1月13日周六 16:51写道： > +1 (non-binding) > > - Validated hashes > - Verified signature > -

Re: [VOTE] Release flink-connector-hbase v3.0.1, release candidate #2

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk11 - Verified web PR Best, Hang Martijn Visser 于2024年1月12日周五 20:30写道： > Hi everyone, > Please review and vote on the release candidate

Re: [DISCUSS] FLIP-417: Expose JobManagerOperatorMetrics via REST API

Hi, Mason. Thanks for driving this FLIP. The JobManagerOperatorQueryScopeInfo has three fields: jobID, vertexID and operatorName. So we should use the operator name in the API. If you think we should use the operator id, there need be more changes about it. About the Xuyang's questions, we add

Re: [VOTE] Release flink-connector-hive, release candidate #1

other setup? > > > [1] https://github.com/apache/flink-connector-hive/actions/runs/7479158667 > > > On Thu, Jan 11, 2024 at 4:44 AM Hang Ruan wrote: > > > Hi, Sergey Nuyanzin. > > > > Thanks for driving this. > >

Re: [VOTE] Release flink-connector-hive, release candidate #1

ive support to be packaged with jdk8 now? Best, Hang Jiabao Sun 于2024年1月11日周四 11:35写道： > +1 (non-binding) > > - Validated checksum hash > - Verified signature > - Verified web PR > - Verified tags > > Best, > Jiabao > > > > 2024年1月11日 11:25，Hang Ruan 写道： &g

Re: [VOTE] Release flink-connector-hive, release candidate #1

Sorry that I make a mistake. I build the source with Maven and jdk11. Best, Hang Hang Ruan 于2024年1月11日周四 11:13写道： > +1 (non-binding) > > - Validated checksum hash > - Verified signature > - Verified that no binaries exist in the source archive > - Build the source w

Re: [VOTE] Release flink-connector-hive, release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven and jdk8 - Verified web PR - Verified that the flink-connector-base is not packaged in hive connector Best, Hang Sergey Nuyanzin 于2024年1月11日周四

Re: Re: [VOTE] FLIP-387: Support named parameters for functions and call procedures

+1 (non-binding) Best, Hang Jingsong Li 于2024年1月10日周三 12:03写道： > +1 > > On Wed, Jan 10, 2024 at 11:24 AM Xuyang wrote: > > > > +1(non-binding)-- > > > > Best！ > > Xuyang > > > > > > > > > > > > 在 2024-01-08 00:34:55，"Feng Jin" 写道： > > >Hi Alexey > > > > > >Thank you for the reminder,

Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (non-binding) Best, Hang gongzhongqiang 于2024年1月9日周二 16:25写道： > +1 non-binding > > Best, > Zhongqiang > > Leonard Xu 于2024年1月9日周二 15:05写道： > > > Hello all, > > > > This is the official vote whether to accept the Flink CDC code > contribution > > to Apache Flink. > > > > The current Flink

Re: [VOTE] FLIP-405: Migrate string configuration key to ConfigOption

+1(non-binding) Best, Hang Rui Fan <1996fan...@gmail.com> 于2024年1月8日周一 13:04写道： > +1(binding) > > Best, > Rui > > On Mon, Jan 8, 2024 at 1:00 PM Xuannan Su wrote: > > > Hi everyone, > > > > Thanks for all the feedback about the FLIP-405: Migrate string > > configuration key to ConfigOption [1]

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations, Alex! Best, Hang Samrat Deb 于2024年1月3日周三 14:18写道： > Congratulations Alex >

Re: [DISCUSS] FLIP-405: Migrate string configuration key to ConfigOption

Hi, Rui Fan. Thanks for this FLIP. I think the key of LOCAL_NUMBER_TASK_MANAGER is better as 'minicluster.number-of-taskmanagers' or 'minicluster.taskmanager-number' instead of 'minicluster.number-taskmanager'. Best, Hang Xuannan Su 于2023年12月27日周三 12:40写道： > Hi Xintong and Rui, > > Thanks

Re: Re: [VOTE] FLIP-372: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable

Thanks for the FLIP. +1 (non-binding) Best, Hang Jiabao Sun 于2023年12月21日周四 11:48写道： > Thanks Peter for driving this. > > +1 (non-binding) > > Best, > Jiabao > > > On 2023/12/18 12:06:05 Gyula Fóra wrote: > > +1 (binding) > > > > Gyula > > > > On Mon, 18 Dec 2023 at 13:04, Márton Balassi > >

Re: [VOTE] Release 1.18.1, release candidate #2

+1 (non-binding) - Validated hashes - Verified signature - Build the source with Maven - Test with the kafka connector 3.0.2: read and write records from kafka in sql client - Verified web PRs Best, Hang Jiabao Sun 于2023年12月20日周三 16:57写道： > Thanks Jing for driving this release. > > +1

Re: 退订

Please send email to user-unsubscr...@flink.apache.org if you want to unsubscribe the mail from u...@flink.apache.org, and you can refer [1][2] for more details. 请发送任意内容的邮件到 user-unsubscr...@flink.apache.org 地址来取消订阅来自 u...@flink.apache.org 邮件组的邮件，你可以参考[1][2] 管理你的邮件订阅。 Best, Hang [1]

Re: Question on lookup joins

Hi, David. The FLIP-377[1] is about this part. You could take a look at it. Best, Hang [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=276105768 Hang Ruan 于2023年12月17日周日 20:56写道： > Hi, David. > > I think you are right that the value with NULL should not be

Re: Question on lookup joins

Hi, David. I think you are right that the value with NULL should not be returned if the filter push down is closed. Maybe you should explain this sql to make sure this filter not be pushed down to the lookup source. I see the configuration 'table.optimizer.source.predicate-pushdown-enabled'

Re: [VOTE] Release flink-connector-pulsar 4.1.0, release candidate #1

+1 (non-binding) - Validated checksum hash - Verified signature - Verified that no binaries exist in the source archive - Build the source with jdk8 - Verified web PR - Make sure flink-connector-base have the provided scope Best, Hang tison 于2023年12月14日周四 11:51写道： > Thanks Leonard for driving

Re: [PROPOSAL] Contribute Flink CDC Connectors project to Apache Flink

+1 for contributing CDC Connectors to Apache Flink. Best, Hang Yuxin Tan 于2023年12月7日周四 16:05写道： > Cool, +1 for contributing CDC Connectors to Apache Flink. > > Best, > Yuxin > > > Jing Ge 于2023年12月7日周四 15:43写道： > > > Awesome! +1 > > > > Best regards, > > Jing > > > > On Thu, Dec 7, 2023 at

Re: Subscribe Apache Flink development email.

Hi, aaron. If you want to subscribe the dev mail list, you need to send an e-mail to dev-subscr...@flink.apache.org . See more in [1]. Mailing list could be found here[2]. Best, Hang [1] https://flink.apache.org/what-is-flink/community/#how-to-subscribe-to-a-mailing-list [2]

Re: [VOTE] Release 1.17.2, release candidate #1

+1 (non-binding) - verified signatures - verified hashsums - Verified there are no binaries in the source archive - reviewed the web PR - built Flink from sources Best, Hang Jiabao Sun 于2023年11月23日周四 22:09写道： > Thanks for driving this release. > > +1(non-binding) > > - Checked the tag in git

Re: [VOTE] Release 1.16.3, release candidate #1

+1 (non-binding) - verified signatures - verified hashsums - Verified there are no binaries in the source archive - reviewed the Release Note - reviewed the web PR Best, Hang Jiabao Sun 于2023年11月23日周四 22:15写道： > Thanks for driving this release. > > +1 (non-binding) > > - Checked the tag in

Re: [VOTE] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

+1(non-binding) Best, Hang Jing Ge 于2023年11月13日周一 16:36写道： > +1(binding) > Thanks! > > Best Regards, > Jing > > On Mon, Nov 13, 2023 at 8:34 AM Zhu Zhu wrote: > > > +1 (binding) > > > > Thanks, > > Zhu > > > > Xia Sun 于2023年11月13日周一 15:02写道： > > > > > +1 (non-binding) > > > > > > Best, > > >

Re: [DISCUSS] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

Thanks Junrui for driving the proposal. +1 from my side. This FLIP will help to make the configuration clearer for users. ps: We should also delete the private field `storage` as its getter and setter are deleted and it is marked as `@Deprecated`. This is not written in the FLIP. Best, Hang

Re: [DISCUSS][FLINK-33240] Document deprecated options as well

Thanks for the proposal. +1 from my side and +1 for putting them to a separate section. Best, Hang Samrat Deb 于2023年11月1日周三 15:32写道： > Thanks for the proposal , > +1 for adding deprecated identifier > > [Thought] Can we have seperate section / page for deprecated configs ? Wdut > ? > > >

Re: [DISCUSS] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

Thanks for the improvements, Jiabao. There are some details that I am not sure about. 1. The new option `source.filter-push-down.enabled` will be added to which class? I think it should be `SourceReaderOptions`. 2. How are the connector developers able to know and follow the FLIP? Do we need an

Re: [ANNOUNCE] Apache Flink 1.18.0 released

Congratulations! Best, Hang Samrat Deb 于2023年10月27日周五 11:50写道： > Congratulations on the great release > > Bests, > Samrat > > On Fri, 27 Oct 2023 at 7:59 AM, Yangze Guo wrote: > > > Great work! Congratulations to everyone involved! > > > > Best, > > Yangze Guo > > > > On Fri, Oct 27, 2023 at

Re: [DISCUSS] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

Hi, all, Thanks for the lively discussion. I agree with Jiabao. I think enabling "scan.filter-push-down.enabled" relies on enabling "table.optimizer.source.predicate-pushdown-enabled". It is a little strange that the planner still needs to push down the filters when we set

Re: [DISCUSS] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

Hi, Jiabao. Thanks for driving this discussion. IMO, if there are many connectors containing the same logic, I think this FLIP is useful. We do not know how many connectors need to add the same code. Best, Hang Jiabao Sun 于2023年10月24日周二 18:26写道： > Thanks Martijn, > > Indeed, implementing the

Re: [VOTE] Release 1.18.0, release candidate #3

+1(non-binding) - verified signatures & hash - build from the source code succeed with jdk 8 - Reviewed release note - Started a standalone cluster and submitted a Flink SQL job that read and wrote with Kafka connector and JSON format Best, Hang Samrat Deb 于2023年10月24日周二 14:06写道： >

Re: [DISCUSS] FLINK-25927: Make flink-connector-base dependency usage consistent across all connectors

Hi, all. I would like to help to do some work about this issue. Because some classes in flink-connector-base are supposed to be used inside the user jar directly, FLINK-25927[1] has been reverted by FLINK-26701[2]. And the final solution is as follows. - package flink-connector-base into

Re: [DISCUSS] FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag

Hi, Xuannan. Thanks for preparing the FLIP. After this FLIP, we will have two ways to report isProcessingBacklog: 1. >From the source; 2. Judged by the watermark lag. What is the priority between them? For example, what is the status isProcessingBacklog when the source report

Re: [ANNOUNCE] New Apache Flink Committer - Hangxiang Yu

Congratulations! Best, Hang Roman Khachatryan 于2023年8月14日周一 22:36写道： > Congratulations, Hangxiang! > > Regards, > Roman > > > On Wed, Aug 9, 2023 at 12:49 PM Benchao Li wrote: > > > Congrats, Hangxiang! > > > > Jing Ge 于2023年8月8日周二 17:44写道： > > > > > Congrats, Hangxiang! > > > > > > Best

Re: [ANNOUNCE] New Apache Flink Committer - Yanfei Lei

Congratulations! Best, Hang Roman Khachatryan 于2023年8月14日周一 22:38写道： > Congratulations, Yanfey! > > Regards, > Roman > > > On Wed, Aug 9, 2023 at 12:49 PM Benchao Li wrote: > > > Congrats, YanFei! > > > > Jing Ge 于2023年8月8日周二 17:41写道： > > > > > Congrats, YanFei! > > > > > > Best regards, > >

[jira] [Created] (FLINK-32862) Support INIT operation type to be compatible with DTS on Alibaba Cloud

Hang Ruan created FLINK-32862: - Summary: Support INIT operation type to be compatible with DTS on Alibaba Cloud Key: FLINK-32862 URL: https://issues.apache.org/jira/browse/FLINK-32862 Project: Flink

Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog

+1 (non-binding) Thanks for driving. Best, Hang Leonard Xu 于2023年7月19日周三 10:42写道： > Thanks Dong for the continuous work. > > +1(binding) > > Best, > Leonard > > > On Jul 18, 2023, at 10:16 PM, Jingsong Li > wrote: > > > > +1 binding > > > > Thanks Dong for continuous driving. > > > > Best, >

Re: [ANNOUNCE] Apache Flink has won the 2023 SIGMOD Systems Award

Hi, Leonard. I would like to help to add this page. Please assign this issue to me. Thanks. Best, Hang Leonard Xu 于2023年7月7日周五 11:26写道： > Congrats to all ! > > It will be helpful to promote Apache Flink if we can add a page to our > website like others[2]. I’ve created an issue to improve

Re: [DISCUSS] FLIP-309: Enable operators to trigger checkpoints dynamically

in a followup FLIP? > >> > > >> > > >> > > > >> > > 3. === > >> > > > >> > > Independent of that, during some brainstorming between me, Chesnay > and > >> > > Stefan Richter, an idea popped up, that I thi

Re: Re: [ANNOUNCE] Apache Flink has won the 2023 SIGMOD Systems Award

Congratulations! Best, Hang Jingsong Li 于2023年7月4日周二 13:47写道： > Congratulations! > > Thank you! All of the Flink community! > > Best, > Jingsong > > On Tue, Jul 4, 2023 at 1:24 PM tison wrote: > > > > Congrats and with honor :D > > > > Best, > > tison. > > > > > > Mang Zhang 于2023年7月4日周二

Re: [DISCUSS] FLIP-309: Enable operators to trigger checkpoints dynamically

Thanks for Dong and Yunfeng's work. The FLIP looks good to me. This new version is clearer to understand. Best, Hang Dong Lin 于2023年6月27日周二 16:53写道： > Thanks Jack, Jingsong, and Zhu for the review! > > Thanks Zhu for the suggestion. I have updated the configuration name as > suggested. > > On

Re: [VOTE] FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

+1 (non-binding) Thanks for Feng driving it. Best, Hang Feng Jin 于2023年6月14日周三 10:36写道： > Hi everyone > > Thanks for all the feedback about the FLIP-295: Support lazy initialization > of catalogs and persistence of catalog configurations[1]. > [2] is the discussion thread. > > > I'd like to

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

; > >>>>> 3. About the open/close method in CatalogStoreFactory. > > >>>> > > >>>> I also agree with the proposed requirement scenario and design. I > have > > >>>> already made modifications to the interface. > > >

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

> > > > affect it. Point 6 described follow-up options for further > > > > > > improvement. > > > > > > > > > > > > > > > > > > Best regards, > > > > > > > > > Jing > > > > &

Re: [VOTE] Release 1.16.2, release candidate #1

+1(non-binding) - reviewed Jira release notes - built from source - verified signatures - verified hashes - verified that no binary exist in the source archive - run streaming job in sql-client successfully Best, Hang Samrat Deb 于2023年5月23日周二 16:23写道： > +1 (non-binding) > > - Verified

Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

+1 (non-binding) Best, Hang Paul Lam 于2023年4月23日周日 11:58写道： > +1 (non-binding) > > Best, > Paul Lam > > > 2023年4月23日 10:57，Shammon FY 写道： > > > > +1 (non-binding) > > > > Best, > > Shammon FY > > > > On Sun, Apr 23, 2023 at 10:35 AM Qingsheng Ren > wrote: > > > >>

Re: [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu

Congratulations, Leonard. Best, Hang Yanfei Lei 于2023年4月23日周日 18:34写道： > Congratulations, Leonard! > > Best, > Yanfei > > liu ron 于2023年4月23日周日 17:45写道： > > > > Congratulations, Leonard. > > > > Best, > > Ron > > > > Zhanghao Chen 于2023年4月23日周日 17:33写道： > > > > > Congratulations, Leonard! >

Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

Congratulations, Qingsheng! Best, Hang Yanfei Lei 于2023年4月23日周日 18:33写道： > Congratulations, Qingsheng! > > Best, > Yanfei > > liu ron 于2023年4月23日周日 17:47写道： > > > > Congratulations, Qingsheng. > > > > Best, > > Ron > > > > Zhanghao Chen 于2023年4月23日周日 17:32写道： > > > > > Congratulations,

Re: Re: [VOTE] FLIP-302: Support TRUNCATE TABLE statement in batch mode

+1 (no-binding) Best, Hang Shammon FY 于2023年4月18日周二 13:33写道： > +1 (no-binding) > > Best, > Shammon FY > > On Tue, Apr 18, 2023 at 12:56 PM Jacky Lau wrote: > > > +1 (no-binding) > > > > Best, > > Jacky Lau > > > > Jingsong Li 于2023年4月18日周二 11:57写道： > > > > > +1 > > > > > > On Tue, Apr 18,

Re: Need Help with Slack Invite Link

Hi, Madhur, I create a new invite link https://join.slack.com/t/apache-flink/shared_invite/zt-1t4khgllz-Fm1CnXzdBbUchBz4HzJCAg . Hope it is useful. Best, Hang Madhur Pyasi 于2023年4月16日周日 05:03写道： > Hello Flink Community, > I am trying to use the slack invite to join the Flink workspace but the

  1   2   >