Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project

2025-06-02 Thread Martijn Visser
+1 (binding) On Mon, Jun 2, 2025 at 9:07 AM Robert Metzger wrote: > +1 (binding) > > > On Mon, Jun 2, 2025 at 8:38 AM Jing Ge wrote: > > > +1(binding) > > > > Best regards, > > Jing > > > > On Mon, Jun 2, 2025 at 3:31 AM Xintong Song > wrote: > > > > > Hi everyone, > > > > > > I'd like to star

Re: [DISCUSS] Flink 1.20.2 release

2025-05-09 Thread Martijn Visser
+1, thanks! On Fri, May 9, 2025 at 3:57 AM Ron Liu wrote: > +1 > > Best, > Ron > > Gabor Somogyi 于2025年5月8日周四 23:52写道: > > > Thanks for volunteering +1. > > > > G > > > > > > On Thu, May 8, 2025 at 5:45 PM Ferenc Csaky > > wrote: > > > > > Hello devs, > > > > > > I would like to start a discus

Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

2025-05-09 Thread Martijn Visser
+1 (binding) On Fri, May 9, 2025 at 9:27 AM Yunfeng Zhou wrote: > +1(non-binding) > > Best, > Yunfeng > > > 2025年5月9日 00:01,Hao Li 写道: > > > > Hi everyone, > > > > I'd like to start a vote on FLIP-525: Model ML_PREDICT, ML_EVALUATE > > Implementation Design [1], which has been discussed in this

[jira] [Created] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP

2025-05-01 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-37753: -- Summary: Improve error handling for UNIX_TIMESTAMP Key: FLINK-37753 URL: https://issues.apache.org/jira/browse/FLINK-37753 Project: Flink Issue Type

Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

2025-04-29 Thread Martijn Visser
Hi all, Thanks for the FLIP Ramin. I would be +1 for this. It creates a consistent experience for SQL users, because they only have to prefix their earlier SQL statement with EXPLAIN in order to get the result. @Ron I don't think it's so much about the efforts that's required to remove the EXECUT

Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #3

2025-04-14 Thread Martijn Visser
Hi Tom, Can you check this on one of the approved releases too, given that this checkstyle issue is 10 years old and listed as a won't fix? Thanks, Martijn On Mon, Apr 14, 2025 at 3:35 PM Tom Cooper wrote: > -1 (non-binding) > > I have tested the RC3, however I have found an issue with the so

[jira] [Created] (FLINK-37614) Make classloading for plannermodule more flexible

2025-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-37614: -- Summary: Make classloading for plannermodule more flexible Key: FLINK-37614 URL: https://issues.apache.org/jira/browse/FLINK-37614 Project: Flink Issue

Re: [VOTE] FLIP-511: Support transaction id pooling in Kafka connector

2025-03-27 Thread Martijn Visser
+1 (binding) On Thu, Mar 27, 2025 at 1:47 PM Yuepeng Pan wrote: > +1 (non-binding) > > Best regards, > Yuepeng Pan > > > > At 2025-03-27 19:16:22, "Roman Khachatryan" wrote: > >+1 (binding) > > > >Regards, > >Roman > > > > > >On Thu, Mar 27, 2025 at 1:18 AM Efrat Levitan > wrote: > > > >> +1 (

Re: [VOTE] FLIP-510: Drop ChangelogNormalize for operations which don't need it

2025-03-12 Thread Martijn Visser
+1 (binding) On Wed, Mar 12, 2025 at 10:21 AM Yuepeng Pan wrote: > +1 (non-binding). > > Best regards, > Yuepeng Pan. > > > > > > > > > > > > At 2025-03-12 17:02:55, "Sergey Nuyanzin" wrote: > >+1 (binding) > > > >On Tue, Mar 11, 2025, 12:38 Xuyang wrote: > > > >> +1(binding) > >> > >> > >> --

Re: FLIP-510: Drop ChangelogNormalize for operations which don't need it

2025-02-27 Thread Martijn Visser
Hi Dawid, Thanks for the FLIP, looks like a good improvement for me that will bring a lot of benefits. +1 Best regards, Martijn On Tue, Feb 25, 2025 at 6:51 AM Sergey Nuyanzin wrote: > +1 for such improvement > > On Mon, Feb 24, 2025 at 12:01 PM Dawid Wysakowicz > wrote: > > > > Hi everyone,

Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0

2025-02-25 Thread Martijn Visser
Hi all, For the record, I don't think we have a guarantee around backwards compatibility for Flink 2.0 anyway, given that we upgraded Scala to the latest version (because of the bump to JDK 17) and that will potentially break savepoints when using Scala. So I think we should also put this in for F

Re: [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation

2025-02-24 Thread Martijn Visser
+1 (binding) Op ma 24 feb 2025 om 11:06 schreef Stefan Richter > +1 (binding) > > Thanks, > Stefan > > On 2025/02/24 14:15:09 Fabian Hüske wrote: > > +1 (binding) > > > > Thank you, > > Fabian > > > > On Mon, Feb 24, 2025 at 12:32 PM Timo Walther > wrote: > > > > > +1 (binding) > > > > > > Than

Re: [VOTE] Release flink-shaded 20.0, release candidate #1

2025-02-20 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PRs Op wo 19 feb 2025 om 16:16 schreef Dawid Wysakowicz > +1 (binding) > > * Verified the signature and checksum > * che

Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans

2025-02-17 Thread Martijn Visser
+1 (binding) On Thu, Feb 13, 2025 at 12:45 PM Samrat Deb wrote: > +1 (non binding) > > Bests, > Samrat > On Thu, 13 Feb 2025 at 5:01 PM, Fabian Hüske > > wrote: > > > +1 (binding) > > > > Cheers, Fabian > > > > On Thu, Feb 13, 2025 at 12:07 PM David Radley > > wrote: > > > > > +1 (non-binding)

[jira] [Created] (FLINK-37291) Weekly Kafka CI detects producer leaks

2025-02-09 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-37291: -- Summary: Weekly Kafka CI detects producer leaks Key: FLINK-37291 URL: https://issues.apache.org/jira/browse/FLINK-37291 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-06 Thread Martijn Visser
Hi Xiangyu Feng, Thanks for the FLIP. Could you elaborate on why Statement Sets aren't sufficient here, I can't find that in the FLIP. Best regards, Martijn On Thu, Feb 6, 2025 at 10:06 AM xiangyu feng wrote: > Hi devs, > > I'm opening this thread to discuss FLIP-506: Support Reuse Multiple T

Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support

2025-01-29 Thread Martijn Visser
+1 (binding) On Tue, Jan 28, 2025 at 1:06 PM Timo Walther wrote: > +1 (binding) > > Thanks, > Timo > > > On 28.01.25 11:56, Fabian Hüske wrote: > > +1 (binding) for this FLIP. > > > > Thank you, > > Fabian > > > > On Tue, Jan 28, 2025 at 2:36 AM Natea Eshetu Beshada > > wrote: > > > >> +1 (non-

Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization

2025-01-29 Thread Martijn Visser
+1 (binding) On Tue, Jan 28, 2025 at 11:57 AM Fabian Hüske wrote: > +1 (binding) for this FLIP. > > Thank you, > Fabian > > On Fri, Jan 24, 2025 at 10:20 AM Timo Walther wrote: > > > +1 (binding) > > > > Thanks for completing this effort. > > > > Cheers, > > Timo > > > > On 23.01.25 22:39, Serg

[ANNOUNCE] Flink master branch default JDK changed to JDK 17

2025-01-15 Thread Martijn Visser
Hi all, With commit 997b48340d2aac1de48c0788b4204d660e34cedd the master branch has been switched to use Java 17 by default. Support for Java 8 has been dropped, and there is a separate profile to run against Java 11 (this is still being run during the cron builds). The README on how to build loca

[jira] [Created] (FLINK-36908) All builds are failing

2024-12-16 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-36908: -- Summary: All builds are failing Key: FLINK-36908 URL: https://issues.apache.org/jira/browse/FLINK-36908 Project: Flink Issue Type: Bug

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

2024-11-25 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR On Thu, Nov 21, 2024 at 9:56 AM Leonard Xu wrote: > +1 (binding) > > - verified signatures > - verified hashsums > - c

Re: Re: [VOTE] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)

2024-11-14 Thread Martijn Visser
I'm very much looking forward to this. Thanks all. +1 (binding) On Wed, Nov 13, 2024 at 5:06 PM David Radley wrote: > +1 (non-binding) > kind regards, > David > > From: Dawid Wysakowicz > Date: Tuesday, 12 November 2024 at 10:47 > To: dev@flink.apache.org > Subject: [EXTERNAL] Re: Re: [VOTE] F

[jira] [Created] (FLINK-36695) Bump Parquet dependency

2024-11-12 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-36695: -- Summary: Bump Parquet dependency Key: FLINK-36695 URL: https://issues.apache.org/jira/browse/FLINK-36695 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

2024-10-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-36591: -- Summary: WikipediaEditsSourceTest fails in all cases Key: FLINK-36591 URL: https://issues.apache.org/jira/browse/FLINK-36591 Project: Flink Issue Type

[jira] [Created] (FLINK-36189) Documentation build is failing with NPM installation problem

2024-08-30 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-36189: -- Summary: Documentation build is failing with NPM installation problem Key: FLINK-36189 URL: https://issues.apache.org/jira/browse/FLINK-36189 Project: Flink

Re: Flink aggregation docs

2024-08-30 Thread Martijn Visser
Hi David, It's already mentioned in the docs: *Note: in order to better understand the behavior of windowing, we simplify the displaying of timestamp values to not show the trailing zeros, e.g. 2020-04-15 08:05 should be displayed as 2020-04-15 08:05:00.000 in Flink SQL Client if the type is TIME

[jira] [Created] (FLINK-36181) Drop support for Java 8 and use Java 17 by default

2024-08-29 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-36181: -- Summary: Drop support for Java 8 and use Java 17 by default Key: FLINK-36181 URL: https://issues.apache.org/jira/browse/FLINK-36181 Project: Flink Issue

[jira] [Created] (FLINK-36116) Javadocs aren't visible anymore for Flink 1.17 and above

2024-08-21 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-36116: -- Summary: Javadocs aren't visible anymore for Flink 1.17 and above Key: FLINK-36116 URL: https://issues.apache.org/jira/browse/FLINK-36116 Project:

Re: [DISCUSS] FLIP-471: Fixing watermark idleness timeout accounting

2024-07-24 Thread Martijn Visser
Hi Piotr, We've talked offline about this proposal and I think it would be beneficial for users to get this fixed. +1 overall, and thanks for writing it down. Best regards, Martijn On Tue, Jul 23, 2024 at 5:45 PM Piotr Nowojski wrote: > Hi All, > > A bit unusual FLIP [1], as this is a bug fix

Re: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-07-18 Thread Martijn Visser
Hi David, The FLIP is updated. Cheers, Martijn On Tue, Jul 16, 2024 at 6:33 PM David Radley wrote: > Hello all, > > > > I have prototyped the new design and confirmed it works. I have documented > the design in google doc > https://docs.google.com/document/d/1J1E-cE-X2H3-kw4rNjLn71OGPQk_Yl1iG

Re: Request to make ContinuousFileReaderOperator public

2024-07-18 Thread Martijn Visser
Hi Darin, Your comment "I think our use case is rather unique and I'm not sure who else would benefit" makes me think then why we should actually support it in Flink, given that you're mentioning the use case is rather unique? Especially since the SourceFunction has many flaws, and has been long o

Re: PR review request for sql-gateway feature

2024-07-18 Thread Martijn Visser
Hi Dongwoo, I think this should first have been a FLIP [1], given that it proposes to make something pluggable with custom interfaces. Best regards, Martijn [1] https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals On Thu, Jul 18, 2024 at 2:50 PM Dongwoo Kim wrote: >

Re: [VOTE] FLIP-465: Introduce DESCRIBE FUNCTION

2024-07-11 Thread Martijn Visser
gt; > > > > > On Thursday, 4 July 2024 at 16:20, Feng Jin > wrote: > > > > > > > > > > > +1 (non-binding) > > > > > > Best, > > > Feng Jin > > > > > > On Thu, Jul 4, 2024 at 6:02 PM Martijn Visser martijnvis...@apache.or

Re: Static OpenSSL lib licensing

2024-07-10 Thread Martijn Visser
Hi Rob, While Netty TCNative has upgraded to Openssl 3, there are still references to BoringSSL [1]. Do you know if TCNative still uses BoringSSL as well in this version? Best regards, Martijn [1] https://github.com/netty/netty-tcnative/blob/netty-tcnative-parent-2.0.62.Final/license/LICENSE.bo

Re: [ANNOUNCE] Release 1.20.0, release candidate #0

2024-07-08 Thread Martijn Visser
Hi all, I've closed my blocker ticket; after force killing all my Flink Java processes, it did work when I restarted it. Thanks, Martijn On Mon, Jul 8, 2024 at 6:13 PM Santwana Verma wrote: > Hi everyone, > > Thanks for creating the release candidate. I've successfully validated the > release

Re: [ANNOUNCE] Release 1.20.0, release candidate #0

2024-07-08 Thread Martijn Visser
Hi all, I've found that no query works in the SQL Client for RC0. See https://issues.apache.org/jira/browse/FLINK-35785 Best regards, Martijn On Fri, Jun 28, 2024 at 6:09 PM weijie guo wrote: > Hi everyone, > > > The release candidate #0(i.e. RC0) for Apache Flink 1.20.0 has been > created. >

[jira] [Created] (FLINK-35785) Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode"

2024-07-08 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35785: -- Summary: Executing query in SQL client results in "java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode" Key: FLINK-35785

Re: Potential Kafka Connector FLIP: Large Message Handling

2024-07-08 Thread Martijn Visser
Hi Kevin, I just want to double check, were you planning to send this proposal to the Kafka Dev mailing list? Because I don't see directly how this affects Flink :) Best regards, Martijn On Mon, Jul 8, 2024 at 8:05 AM Grace Grimwood wrote: > Hi Kevin, > > Thanks for starting this thread. > >

Re: [VOTE] FLIP-465: Introduce DESCRIBE FUNCTION

2024-07-04 Thread Martijn Visser
+1 (binding) On Thu, Jul 4, 2024 at 5:39 AM Yanquan Lv wrote: > Hi Natea, thanks for driving it. > +1 (non-binding). > > Jim Hughes 于2024年7月4日周四 04:41写道: > > > Hi Natea, > > > > Looks good to me! > > > > +1 (non-binding). > > > > Cheers, > > > > Jim > > > > On Wed, Jul 3, 2024 at 3:16 PM Natea

Re: [DISCUSS] FLIP-299 Pub/Sub Lite Connector

2024-07-02 Thread Martijn Visser
repository ... be removed ... ? > > > > Yes, I would remove it once it is merged into a version of flink that is > > supported by GCP dataproc. It exists now (and I am creating releases and > > maven artifacts for it) to unblock users in the interim period. > > >

Re: [VOTE] FLIP-456: CompiledPlan support for Batch Execution Mode

2024-07-02 Thread Martijn Visser
+1 (binding) On Mon, Jul 1, 2024 at 7:00 PM Jim Hughes wrote: > Hi Alexey, > > +1 (non-binding) > > I'm looking forward to parity between streaming and batch bound for > compiled plans! > > Cheers, > > Jim > > On Mon, Jul 1, 2024 at 12:55 PM Alexey Leonov-Vendrovskiy < > vendrov...@gmail.com> wr

Re: [VOTE] Release flink-shaded 19.0, release candidate #1

2024-07-01 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PRs On Fri, Jun 28, 2024 at 2:02 PM Timo Walther wrote: > +1 (binding) > > Thanks for fixing the JSON functions! > > Timo

Re: [VOTE] FLIP-444: Native file copy support

2024-06-27 Thread Martijn Visser
+1 (binding) On Thu, Jun 27, 2024 at 3:32 AM Rui Fan <1996fan...@gmail.com> wrote: > +1(binding) > > Best, > Rui > > On Wed, Jun 26, 2024 at 10:22 PM Stefan Richter > wrote: > > > > > +1 (binding) > > > > Best, > > Stefan > > > > > > > > > On 26. Jun 2024, at 16:14, Hong wrote: > > > > > > +1 (

Re: [VOTE] FLIP-463: Schema Definition in CREATE TABLE AS Statement

2024-06-25 Thread Martijn Visser
+1 (binding) On Sun, Jun 23, 2024 at 9:07 PM Ferenc Csaky wrote: > +1 (non-binding) > > Best, > Ferenc > > > > > On Sunday, June 23rd, 2024 at 05:13, Yanquan Lv > wrote: > > > > > > > Thnaks Sergio, +1 (non-binding) > > > > gongzhongqiang gongzhongqi...@apache.org 于2024年6月23日周日 10:06写道: > > > >

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

2024-06-11 Thread Martijn Visser
Hi David, That's a blocker for a Flink Kafka connector 4.0, not for 3.2.0. It's not related to this release. Best regards, Martijn On Tue, Jun 11, 2024 at 3:54 PM David Radley wrote: > Hi, > Sorry I am a bit late. > I notice https://issues.apache.org/jira/browse/FLINK-35109 is open and a > bl

[jira] [Created] (FLINK-35566) Consider promoting TypeSerializer from PublicEvolving to Public

2024-06-11 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35566: -- Summary: Consider promoting TypeSerializer from PublicEvolving to Public Key: FLINK-35566 URL: https://issues.apache.org/jira/browse/FLINK-35566 Project: Flink

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

2024-06-06 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PRs On Tue, Jun 4, 2024 at 11:08 AM Fabian Paul wrote: > +1 (non-binding) > > - Verified signature > - Verified checksum

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2024-05-24 Thread Martijn Visser
s > > > anything important that I might have missed. > > > > > > Best, > > > Alex > > > > > > [1] https://cwiki.apache.org/confluence/x/BApeEg > > > > > > > > > On Tue, 23 Jan 2024 at 03:30, Rui Fan <1996fan...@gmail.

Re: [VOTE] FLIP-443: Interruptible watermark processing

2024-05-24 Thread Martijn Visser
+1 (binding) On Fri, May 24, 2024 at 7:31 AM weijie guo wrote: > +1(binding) > > Thanks for driving this! > > Best regards, > > Weijie > > > Rui Fan <1996fan...@gmail.com> 于2024年5月24日周五 13:03写道: > > > +1(binding) > > > > Best, > > Rui > > > > On Fri, May 24, 2024 at 12:01 PM Yanfei Lei wrote: >

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

2024-05-17 Thread Martijn Visser
Hi all, I'm happy to announce that we have unanimously approved FLIP-453. There were 12 votes, of which 4 were binding. - weijie guo (binding) - Ferenc Csaky (non-binding) - Rui Fan (binding) - Zhongqiang Gong (non-binding) - Péter Váry (non-binding) - Rodrigo Meneses (non-binding) - lorenzo affe

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

2024-05-17 Thread Martijn Visser
:04, "Jing Ge" wrote: > >>> +1(binding) Thanks Martijn! > >>> > >>> Best regards, > >>> Jing > >>> > >>> On Wed, May 15, 2024 at 7:00 PM Muhammet Orazov > >>> wrote: > >>> > >>&

Re: [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option

2024-05-16 Thread Martijn Visser
s > > Keith Lee > > [1] > > https://cwiki.apache.org/confluence/plugins/servlet/mobile?contentId=65145551#FlinkImprovementProposals-Whatisconsidereda%22majorchange%22thatneedsaFLIP > ? > > > On Thu, 16 May 2024 at 13:03, Martijn Visser > wrote: > > > Hi Keith Lee,

[jira] [Created] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc

2024-05-16 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35378: -- Summary: [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc Key: FLINK-35378 URL: https://issues.apache.org/jira/browse/FLINK-35378 Project

Re: [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option

2024-05-16 Thread Martijn Visser
Hi Keith Lee, There is actually an open and accepted FLIP [1] that was just never implemented. I think that needs to be taken into account as well, since it was voted on. I think it also makes more sense to have a proposal as a FLIP, instead of under a Jira. Best regards, Martijn [1] https://cw

[jira] [Created] (FLINK-35350) Add documentation for Kudu

2024-05-14 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35350: -- Summary: Add documentation for Kudu Key: FLINK-35350 URL: https://issues.apache.org/jira/browse/FLINK-35350 Project: Flink Issue Type: Sub-task

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

2024-05-13 Thread Martijn Visser
Hi everyone, With no more discussions being open in the thread [1] I would like to start a vote on FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction [2] The vote will be open for at least 72 hours unless there is an objection or insufficient votes. Best regards, Martijn

Re: [jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism

2024-05-13 Thread Martijn Visser
rds > Keith Lee > > > On Mon, May 13, 2024 at 1:27 PM Martijn Visser (Jira) > wrote: > > > > > [ > > > https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel > > ] > > > > Martij

[jira] [Created] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests

2024-05-13 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35333: -- Summary: JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests Key: FLINK-35333 URL: https://issues.apache.org/jira/browse/FLINK-35333 Project: Flink

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

2024-05-13 Thread Martijn Visser
nted? > > > > Could you please clarify? > > Best Regards > Ahmed Hamdy > > > On Sun, 12 May 2024 at 14:07, Martijn Visser > wrote: > > > Hi all, > > > > If there are no more considerations, I'll open up a vote in the next > couple >

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

2024-05-12 Thread Martijn Visser
t; >>> With regards to FLINK-35149, the fix version indicates a change at > > Flink > > >> CDC; is that indeed correct, or does it require a change in the SinkV2 > > >> interface? > > >> > > >> The fix doesn't need change in SinkV2, so w

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

2024-05-03 Thread Martijn Visser
> Also, I volunteer to take updating the HBase sink, feel free to assign > that task to me. > > Best, > Ferenc > > > > > On Friday, May 3rd, 2024 at 10:20, Martijn Visser < > martijnvis...@apache.org> wrote: > > > > > > > Hi Peter, > >

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

2024-05-03 Thread Martijn Visser
pull/10179 > [3] - https://issues.apache.org/jira/browse/FLINK-35149 > > > On Thu, May 2, 2024, 09:47 Muhammet Orazov > wrote: > > > Got it, thanks! > > > > On 2024-05-02 06:53, Martijn Visser wrote: > > > Hi Muhammet, > > > > > > Thank

Re: FW: RE: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-05-02 Thread Martijn Visser
4-eCHWLgE/edit?usp=sharing > > The original version you have copied is a bit out-dated and verbose. > Please could you replace the Flip with content from the above link, > Kind regards, David, > > From: Martijn Visser > Date: Wednesday, 1 May 2

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

2024-05-01 Thread Martijn Visser
P and detailed history of changes, +1. > > Would FLIP changes target for 2.0? I think it would be good > to have clear APIs on 2.0 release. > > Best, > Muhammet > > On 2024-05-01 15:30, Martijn Visser wrote: > > Hi everyone, > > > > I would like to start a

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

2024-05-01 Thread Martijn Visser
Hi everyone, I would like to start a discussion on FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction https://cwiki.apache.org/confluence/x/rIobEg This FLIP proposes to promote the Unified Sink API V2 from PublicEvolving to Public and to mark the SinkFunction as Deprecated

Re: FW: RE: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-05-01 Thread Martijn Visser
d the template in a new Google Doc > https://docs.google.com/document/d/1J1E-cE-X2H3-kw4rNjLn71OGPQk_Yl1iGX4-eCHWLgE/edit?usp=sharing. > I have significantly reduced the content in the Flip, in line with what I > see as the template and its usage. If this it too much or too little, I can

[jira] [Created] (FLINK-35280) Migrate HBase Sink connector to use the ASync Sink API

2024-05-01 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35280: -- Summary: Migrate HBase Sink connector to use the ASync Sink API Key: FLINK-35280 URL: https://issues.apache.org/jira/browse/FLINK-35280 Project: Flink

Re: [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration

2024-04-25 Thread Martijn Visser
t; anything and if it is related to pluggable enricher FLIP or anyway we can > use pluggable enricker FLIP here for CRUD failures. > > Regards, > Swathi C > > -- Forwarded message - > From: Martijn Visser > Date: Thu, Apr 25, 2024 at 2:46 AM > Subject: Re:

Re: [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration

2024-04-24 Thread Martijn Visser
> > of work is a subset (Further implementation) we can just add a Jira > ticket > > for it. IMO this will also help with implementation taking the existing > > enrichers into reference. > > Best Regards > > Ahmed Hamdy > > > > > > On Tue, 23 Apr 2

Re: [DISCUSS] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

2024-04-24 Thread Martijn Visser
+1 On Wed, Apr 24, 2024 at 5:31 PM Congxian Qiu wrote: > Thanks for driving this, yue > > We also observed significant performance improvements in some cases after > bumped the Rocksdb version, +1 for this work > > Best, > Congxian > > > yue ma 于2024年4月24日周三 19:16写道: > > > hi Yanfei, > > > > T

Re: [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration

2024-04-23 Thread Martijn Visser
>From a procedural point of view, we shouldn't make FLIPs sub-tasks for existing FLIPs that have been voted/are released. That will only cause confusion down the line. A new FLIP should take existing functionality (like FLIP-304) into account, and propose how to improve on what that original FLIP h

Re: [VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-19 Thread Martijn Visser
+1 (binding) On Fri, Apr 19, 2024 at 10:07 AM Yuepeng Pan wrote: > +1(non-binding) > > Best, > Yuepeng Pan > > At 2024-04-19 15:22:04, "gongzhongqiang" > wrote: > >+1(non-binding) > > > > > >Best, > > > >Zhongqiang Gong > > > >Ron liu 于2024年4月17日周三 14:28写道: > > > >> Hi Dev, > >> > >> Thank you

[jira] [Created] (FLINK-35109) Drop support for Flink 1.17 and 1.18 in Flink Kafka connector

2024-04-15 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35109: -- Summary: Drop support for Flink 1.17 and 1.18 in Flink Kafka connector Key: FLINK-35109 URL: https://issues.apache.org/jira/browse/FLINK-35109 Project: Flink

Re: [EXTERNAL] RE: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-04-12 Thread Martijn Visser
Hi David, I tried, but the format wasn't as the FLIP template expects, so I ended up needing to change the entire formatting and that was just too much work to be honest. If you could make sure that especially the headers match with the FLIP template, and that all of the contents from the FLIP tem

Re: Proposal: I hope the official documentation can provide an "Integrations" section.

2024-04-12 Thread Martijn Visser
Hi Kaiming, Since AutoMQ isn't part of the ASF Flink project, I'm not sure if it makes sense to document this in the Flink documentation. There are many technologies compatible with the Kafka API, but we also don't have those listed in our docs and I don't think we should. Best regards, Martijn

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

2024-04-11 Thread Martijn Visser
+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, > > Feng > > > > On Tue, Apr 9, 2024 at 5:56 PM gongzhongqiang > > > wrote: > > > > > +1 (non-binding) > >

[jira] [Created] (FLINK-35009) Change on getTransitivePredecessors breaks connectors

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35009: -- Summary: Change on getTransitivePredecessors breaks connectors Key: FLINK-35009 URL: https://issues.apache.org/jira/browse/FLINK-35009 Project: Flink

[jira] [Created] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35008: -- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector Key: FLINK-35008 URL: https://issues.apache.org/jira/browse/FLINK-35008

[jira] [Created] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35007: -- Summary: Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT Key: FLINK-35007 URL: https://issues.apache.org/jira/browse/FLINK-35007 Project

Re: [DISCUSS] Externalized Google Cloud Connectors

2024-04-04 Thread Martijn Visser
Hi Lorenzo, Bahir is retired, see the homepage. It plays no role (anymore). > This, unfortunately, is the tradeoff for developing the connectors outside of Apache in exchange for development velocity. I understand that. It can be considered to develop the connectors outside of the Flink project

Re: [DISCUSS] FLIP-435: Introduce a New Dynamic Table for Simplifying Data Pipelines

2024-04-03 Thread Martijn Visser
Hi all, Thanks for the proposal. While the FLIP talks extensively on how Snowflake has Dynamic Tables and Databricks has Delta Live Tables, my understanding is that Databricks has CREATE STREAMING TABLE [1] which relates with this proposal. I do have concerns about using CREATE DYNAMIC TABLE, spe

Re: [VOTE] FLIP-437: Support ML Models in Flink SQL

2024-04-03 Thread Martijn Visser
+1 (binding) On Wed, Apr 3, 2024 at 9:52 AM Leonard Xu wrote: > +1(binding) > > Best, > Leonard > > > 2024年4月3日 下午3:37,Piotr Nowojski 写道: > > > > +1 (binding) > > > > Best, > > Piotrek > > > > śr., 3 kwi 2024 o 04:29 Yu Chen napisał(a): > > > >> +1 (non-binding) > >> > >> Looking forward to th

Re: [DISCUSS] Flink Website Menu Adjustment

2024-03-25 Thread Martijn Visser
Hi Zhongqiang Gong, Are you suggesting to continuously update the menu based on the number of releases, or just this one time? I wouldn't be in favor of continuously updating: returning customers expect a certain order in the menu, and I don't see a lot of value in continuously changing that. I do

Re: [VOTE] FLIP-402: Extend ZooKeeper Curator configurations

2024-03-21 Thread Martijn Visser
+1 (binding) On Wed, Mar 20, 2024 at 1:19 PM Ferenc Csaky wrote: > +1 (non-binding), thanks for driving this! > > Best, > Ferenc > > > On Wednesday, March 20th, 2024 at 10:57, Yang Wang < > wangyang0...@apache.org> wrote: > > > > > > > +1 (binding) since ZK HA is still widely used. > > > > > > B

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

2024-03-21 Thread Martijn Visser
+1 (binding) On Thu, Mar 21, 2024 at 8:01 AM gongzhongqiang wrote: > +1 (non-binding) > > Bests, > Zhongqiang Gong > > Ferenc Csaky 于2024年3月20日周三 22:11写道: > > > Hello devs, > > > > I would like to start a vote about FLIP-439 [1]. The FLIP is about to > > externalize the Kudu > > connector from

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

2024-03-14 Thread Martijn Visser
+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven via mvn clean install -Pcheck-convergence -Dflink.version=1.19.0 - Verified licenses - Verified web PR - Started a cluster and the Flink SQL client, successful

Re: [DISCUSS] Externalized Google Cloud Connectors

2024-03-08 Thread Martijn Visser
Hi Claire, I don't think it's a good idea to actually develop outside of Apache; contributions that have happened outside of the Apache realm do not play a role when evaluating potential new committers. I think the best course of action would be to create a FLIP to add these connectors to the ASF,

Re: [DISCUSS] FLIP-419: Optimize multi-sink query plan generation

2024-03-08 Thread Martijn Visser
Hi Jeyhun Karimov, I see that you've already opened up a VOTE thread, but since you're talking about having a prototype already and results, I wondered if you could include the POC and how you've tested these results in the FLIP? Best regards, Martijn On Tue, Jan 30, 2024 at 4:47 AM Jeyhun Kari

Re: [DISCUSS] Add "Special Thanks" Page on the Flink Website

2024-03-08 Thread Martijn Visser
Hi all, I'm +1 on it. As long as we follow the ASF rules on this, we can thank those that are/have made contributions. Best regards, Martijn On Wed, Mar 6, 2024 at 7:45 AM Jark Wu wrote: > Hi Matthias, > > Thanks for your comments! Please see my reply inline. > > > What do we do if we have en

Re: [DISCUSS] Support the Ozone Filesystem

2024-03-08 Thread Martijn Visser
Hi Ferenc, I'm +0: I have seen no demand for Ozone, but if the community is OK with it, why not. Best regards, Martijn On Mon, Feb 26, 2024 at 6:08 AM Ferenc Csaky wrote: > Hi, > > gentle reminder on this thread, any opinions or thoughts? > > Regards, > Ferenc > > > > > On Thursday, February

[jira] [Created] (FLINK-34621) Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base

2024-03-07 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34621: -- Summary: Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre in /flink-connector-hbase-base Key: FLINK-34621 URL: https://issues.apache.org/jira/browse/FLINK-34621

Re: Default scale and precision SQL data types

2024-03-03 Thread Martijn Visser
Hi, I think it would first require a FLIP, given it touches on the core type system of SQL. Best regards, Martijn On Sat, Mar 2, 2024 at 5:34 PM Sergei Morozov wrote: > Hi there, > > org.apache.flink.table.api.DataTypes allows the creation of temporal data > types by specifying precision (e.g

Re: [DISCUSS] Apache Bahir retired

2024-02-28 Thread Martijn Visser
Hi all, +1 to have a connector FLIP to propose a Kudu connector. I'm +0 overall because I don't see a lot of activity happening in newly proposed connectors, but if there's demand for it and people want to volunteer with contributions, there's no reason to block it. Best regards, Martijn On Wed

Re: [DISCUSS] Alternative way of posting FLIPs

2024-02-26 Thread Martijn Visser
Hi all, I've created https://issues.apache.org/jira/browse/FLINK-34515 and updated https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals to update the instructions for the community. Best regards, Martijn On Thu, Feb 15, 2024 at 10:04 AM Martijn Visser wrote: &

[jira] [Created] (FLINK-34515) Document new FLIP process

2024-02-26 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34515: -- Summary: Document new FLIP process Key: FLINK-34515 URL: https://issues.apache.org/jira/browse/FLINK-34515 Project: Flink Issue Type: New Feature

Re: FW: RE: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

2024-02-19 Thread Martijn Visser
I'm a bit confused: did we add new interfaces after FLIP-314 was accepted? If so, please move the new interfaces to a new FLIP and start a separate vote. We can't retrospectively change an accepted FLIP with new interfaces and a new vote. On Mon, Feb 19, 2024 at 3:22 AM Yong Fang wrote: > > Hi al

[jira] [Created] (FLINK-34461) MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17

2024-02-19 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34461: -- Summary: MongoDB weekly builds fail with time out on Flink 1.18.1 for JDK17 Key: FLINK-34461 URL: https://issues.apache.org/jira/browse/FLINK-34461 Project

Re: FLINK-21672

2024-02-16 Thread Martijn Visser
may not be considered a feature > right Martijn? > If it's a test improvement, can it still be part of the release? > > Gyula > > On Fri, Feb 16, 2024 at 4:45 PM Martijn Visser > wrote: > > > Hi David, > > > > Happy to assign it to you. It can't

Re: FLINK-21672

2024-02-16 Thread Martijn Visser
Hi David, Happy to assign it to you. It can't be merged for Flink 1.19 anymore though: feature freeze has started for that one, as announced previously on the mailing list. Best regards, Martijn On Fri, Feb 16, 2024 at 4:32 PM David Radley wrote: > > Hi, > I see https://issues.apache.org/jira/

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

2024-02-15 Thread Martijn Visser
Hi Etienne, > I fixed the source release [1] as requested, it no more contains > tools/release/shared directory. I don't think that is the correct way: my understanding is that this invalidates basically all the votes, because now the checked artifact has changed. It was requested to file a tick

  1   2   3   4   5   6   7   8   9   10   >