Re: [DISCUSS] Flink 1.19.1 release

Hello, Thanks for opening this discussion Hong. +1 for the 1.19.1 release and +1 for Hong as release manager. I am happy to help out, however I will not be back at my laptop until 5th June onwards. Danny. On Fri, May 24, 2024 at 1:57 PM Hong Liang wrote: > Hi all, > > I would like to discuss

Re: [VOTE] FLIP-454: New Apicurio Avro format

hjb > > kind regards, David. > > From: Danny Cranmer > Date: Tuesday, 14 May 2024 at 11:58 > To: dev@flink.apache.org > Subject: [EXTERNAL] Re: [VOTE] FLIP-454: New Apicurio Avro format > Hello all, > > Thanks for Driving this David. I am +1 for adding support for the

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

t; [2] https://github.com/apache/flink-connector-kafka/pull/99 > [3] > https://www.apicur.io/registry/docs/apicurio-registry/2.5.x/getting-started/assembly-configuring-kafka-client-serdes.html#registry-serdes-types-json_registry > > > > > > > > > > > > > F

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

Hello, Apologies, I am on vacation and have limited access to email. I can see the logic here and why you ended up where you did. I can also see there are other useful metadata fields that we might want to pass through, which might result in this Map being abused (Kafka Topic, Kinesis Shard,

Re: [VOTE] FLIP-454: New Apicurio Avro format

Hello all, Thanks for Driving this David. I am +1 for adding support for the new format, however have some questions/suggestions on the details. 1. Passing around Map additionalInputProperties feels a bit dirty. It looks like this is mainly for the Kafka connector. This connector already has a

Re: [VOTE] FLIP-454: New Apicurio Avro format

t; > > > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-454%3A+New+Apicurio+Avro+format > > > > [2] https://lists.apache.org/thread/wtkl4yn847tdd0wrqm5xgv9wc0cb0kr8 > > > > > > > > > > > > Kind regards, David. > > > > > > > > Unless otherwise stated above: > > > > > > > > IBM United Kingdom Limited > > > > Registered in England and Wales with number 741598 > > > > Registered office: PO Box 41, North Harbour, Portsmouth, Hants. PO6 > 3AU > > > > > > > > > > -- Best Regards Danny Cranmer

Re: [VOTE] FLIP-451: Introduce timeout configuration to AsyncSink

Thanks for driving this Ahmed. This is a nice improvement to the API: +1 (binding) Thanks, Danny On Mon, May 13, 2024 at 7:58 PM Ahmed Hamdy wrote: > Thanks David, > I have replied to your question in the discussion thread. > Best Regards > Ahmed Hamdy > > > On Mon, 13 May 2024 at 16:21,

Re: [DISCUSS] Connector releases for Flink 1.19

this! > > > > > > I can help with the HBase connector if necessary, will comment the > > > details to the relevant Jira ticket. > > > > > > Best, > > > Ferenc > > > > > > > > > > > > > > > On Wednesday, April 17th

Re: flink-connector-kafka weekly CI job failing

Hello, Is there a reason we cannot fix the code rather than disabling the test? If we skip the tests this will likely be missed and cause delays for 1.20 support down the road. Thanks, Danny On Wed, 8 May 2024, 23:35 Robert Young, wrote: > Hi, > > I noticed the flink-connector-kafka weekly CI

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

Hi everyone, Please review and vote on release candidate #1 for flink-connector-kafka v3.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for your

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

Hi everyone, Please review and vote on release candidate #1 for flink-connector-cassandra v3.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for

[jira] [Created] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector

Danny Cranmer created FLINK-35174: - Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector Key: FLINK-35174 URL: https://issues.apache.org/jira/browse/FLINK-35174

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

Hi everyone, Please review and vote on release candidate #2 for flink-connector-aws v4.3.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This version supports Flink 1.18 and 1.19. The complete staging area is available for your

Re: [DISCUSS][QUESTION] Drop jdk 8 support for Flink connector Opensearch

Hey Sergey, Given the circumstances I think it is ok to drop JDK 8 support with the opensearch v2.0.0 connector. However, in parallel we should still support the 1.x line for Flink 1.x series with JDK 8. This would mean two releases: 1/ flink-connector-opensearch v2.0.0 for Flink 1.18/1.19,

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

Hi everyone, Please review and vote on release candidate #1 for flink-connector-gcp-pubsub v3.1.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for

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

Sorry for typos: > Please review and vote on the release candidate #1 for the version 3.2.0, as follows: Should be "release candidate #2" > * source code tag v3.2.0-rc1 [5], Should be "source code tag v3.2.0-rc2" Thanks, Danny On Thu, Apr 18, 2024 at 11:19 AM D

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

Hi everyone, Please review and vote on the release candidate #2 for v1.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for your review, which

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

Hi everyone, Please review and vote on the release candidate #1 for the version 3.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for your review,

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

ature > > - CI passed with tag v1.2.0-rc1 > > > > Best, > > Zhongqiang Gong > > > > Danny Cranmer 于2024年4月17日周三 18:44写道： > > > > > Hi everyone, > > > > > > Please review and vote on the release candidate #1 for v1.2.0, as >

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

Checked release note page. > > > Thanks for driving it! > > > Best, > Yuepeng Pan > > > > > At 2024-04-17 18:02:06, "Danny Cranmer" wrote: > >Hi everyone, > > > >Please review and vote on the release candidate #1 for the version

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

Hey, Thanks for root causing this. I agree this needs to be fixed. -1 binding Thanks, Danny On Wed, 17 Apr 2024, 15:43 Aleksandr Pilipenko, wrote: > Hi Danny, > > There is a blocker bug reported in Kinesis connector [1] > We should pause the release until it is resolved. > > [1] >

[VOTE] Release flink-connector-mongodb v1.2.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for v1.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for your review, which

[jira] [Created] (FLINK-35141) Release flink-connector-pulsar vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35141: - Summary: Release flink-connector-pulsar vX.X.X for Flink 1.19 Key: FLINK-35141 URL: https://issues.apache.org/jira/browse/FLINK-35141 Project: Flink Issue

[jira] [Created] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.18/1.19

Danny Cranmer created FLINK-35134: - Summary: Release flink-connector-elasticsearch vX.X.X for Flink 1.18/1.19 Key: FLINK-35134 URL: https://issues.apache.org/jira/browse/FLINK-35134 Project: Flink

[VOTE] Release flink-connector-jdbc v3.2.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 3.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Flink 1.18 and 1.19. The complete staging area is available for your review,

[jira] [Created] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35136: - Summary: Release flink-connector-hbase vX.X.X for Flink 1.19 Key: FLINK-35136 URL: https://issues.apache.org/jira/browse/FLINK-35136 Project: Flink Issue

[jira] [Created] (FLINK-35142) Release flink-connector-rabbitmq vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35142: - Summary: Release flink-connector-rabbitmq vX.X.X for Flink 1.19 Key: FLINK-35142 URL: https://issues.apache.org/jira/browse/FLINK-35142 Project: Flink

[jira] [Created] (FLINK-35140) Release flink-connector-opensearch vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35140: - Summary: Release flink-connector-opensearch vX.X.X for Flink 1.19 Key: FLINK-35140 URL: https://issues.apache.org/jira/browse/FLINK-35140 Project: Flink

Re: [DISCUSS] Connector releases for Flink 1.19

:41 PM Muhammet Orazov wrote: > Thanks Sergey and Danny for clarifying, indeed it > requires committer to go through the process. > > Anyway, please let me know if I can be any help. > > Best, > Muhammet > > > On 2024-04-16 11:19, Danny Cranmer wrote: > > H

[jira] [Created] (FLINK-35133) Release flink-connector-cassandra v4.3.0 for Flink 1.18/1.19

Danny Cranmer created FLINK-35133: - Summary: Release flink-connector-cassandra v4.3.0 for Flink 1.18/1.19 Key: FLINK-35133 URL: https://issues.apache.org/jira/browse/FLINK-35133 Project: Flink

[jira] [Created] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35139: - Summary: Release flink-connector-mongodb vX.X.X for Flink 1.19 Key: FLINK-35139 URL: https://issues.apache.org/jira/browse/FLINK-35139 Project: Flink

[jira] [Created] (FLINK-35138) Release flink-connector-kafka vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35138: - Summary: Release flink-connector-kafka vX.X.X for Flink 1.19 Key: FLINK-35138 URL: https://issues.apache.org/jira/browse/FLINK-35138 Project: Flink Issue

[jira] [Created] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35137: - Summary: Release flink-connector-jdbc vX.X.X for Flink 1.19 Key: FLINK-35137 URL: https://issues.apache.org/jira/browse/FLINK-35137 Project: Flink Issue

[jira] [Created] (FLINK-35135) Release flink-connector-gcp-pubsub vX.X.X for Flink 1.18/1.19

Danny Cranmer created FLINK-35135: - Summary: Release flink-connector-gcp-pubsub vX.X.X for Flink 1.18/1.19 Key: FLINK-35135 URL: https://issues.apache.org/jira/browse/FLINK-35135 Project: Flink

[jira] [Created] (FLINK-35132) Release flink-connector-aws v4.3.0 for Flink 1.18/1.19

Danny Cranmer created FLINK-35132: - Summary: Release flink-connector-aws v4.3.0 for Flink 1.18/1.19 Key: FLINK-35132 URL: https://issues.apache.org/jira/browse/FLINK-35132 Project: Flink

[jira] [Created] (FLINK-35131) Support and Release Connectors for Flink 1.19

Danny Cranmer created FLINK-35131: - Summary: Support and Release Connectors for Flink 1.19 Key: FLINK-35131 URL: https://issues.apache.org/jira/browse/FLINK-35131 Project: Flink Issue Type

Re: [DISCUSS] Connector releases for Flink 1.19

; wrote: > >> Hello Danny, >> >> I would like to work on this task, thanks for initiating it! >> >> I could update the versions on JDBC and Pulsar connectors. >> >> Are you going to create an umbrella issue for it? >> >> Best, >> Muhamm

[VOTE] Release flink-connector-aws v4.3.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for flink-connector-aws v4.3.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This release supports Apache Flink 1.18 and 1.19. The complete staging area is available

[jira] [Created] (FLINK-35124) Connector Release Fails to run Checkstyle

Danny Cranmer created FLINK-35124: - Summary: Connector Release Fails to run Checkstyle Key: FLINK-35124 URL: https://issues.apache.org/jira/browse/FLINK-35124 Project: Flink Issue Type: Bug

[DISCUSS] Connector releases for Flink 1.19

Hello all, Flink 1.19 was released on 2024-03-18 [1] and the connectors have not yet caught up. I propose we start releasing the connectors with support for Flink 1.19 as per the connector support guidelines [2]. I will make a start on flink-connector-aws, then pickup others in the coming days.

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

Congrats Jing! Best Regards, Danny On Mon, Apr 15, 2024 at 11:51 AM Swapnal Varma wrote: > Congratulations, Jing! > > Best, > Swapnal > > On Mon, 15 Apr 2024, 15:14 Jacky Lau, wrote: > > > Congratulations, Jing! > > > > Best, > > Jacky Lau > > >

Re: [Vote] FLIP-438: Amazon SQS Sink Connector

Thanks for driving this Priya. +1 (binding) Danny. On Sun, Apr 14, 2024 at 12:33 PM Samrat Deb wrote: > +1 (non-binding) > > Bests, > Samrat > > On Sun, 14 Apr 2024 at 3:38 PM, Ahmed Hamdy wrote: > > > Hi Priya > > +1 (non-binding) > > Best Regards > > Ahmed Hamdy > > > > > > On Fri, 12 Apr

Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector

Thanks for the FLIP Priya. I have seen many custom implementations of SQS sinks, so having an Apache supported connector will be great. I agree on the points about implementation detail in the FLIP. There is still too much code really, we will review that in the PR. The FLIP is mainly to agree we

[jira] [Created] (FLINK-35113) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink AWS connectors

Danny Cranmer created FLINK-35113: - Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink AWS connectors Key: FLINK-35113 URL: https://issues.apache.org/jira/browse/FLINK-35113

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

Congrats Zakelly! Danny. On Mon, Apr 15, 2024 at 9:26 AM Xia Sun wrote: > Congratulations Zakelly! > > Best, > Xia > > Leonard Xu 于2024年4月15日周一 16:16写道： > > > Congratulations Zakelly! > > > > > > Best, > > Leonard > > > 2024年4月15日 下午3:56，Samrat Deb 写道： > > > > > > Congratulations Zakelly!

Re: [VOTE] FLIP-418: Show data skew score on Flink Dashboard

Thanks for driving thie Emre, +1 (binding) Thanks, Danny. On Mon, Feb 12, 2024 at 9:42 PM Hong Liang wrote: > +1 (binding) > > Thank you for driving this Emre! This is a good step towards better user > experience when diagnosing performance issues with Flink jobs. > > Best, > Hong > > On Wed,

[jira] [Created] (FLINK-34342) Address ListShards Consistency for DDB Streams Source

Danny Cranmer created FLINK-34342: - Summary: Address ListShards Consistency for DDB Streams Source Key: FLINK-34342 URL: https://issues.apache.org/jira/browse/FLINK-34342 Project: Flink

[jira] [Created] (FLINK-34341) Implement DDB Streams Table API support

Danny Cranmer created FLINK-34341: - Summary: Implement DDB Streams Table API support Key: FLINK-34341 URL: https://issues.apache.org/jira/browse/FLINK-34341 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-34340) Add support for DDB Streams

Danny Cranmer created FLINK-34340: - Summary: Add support for DDB Streams Key: FLINK-34340 URL: https://issues.apache.org/jira/browse/FLINK-34340 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34339) Add connector abstraction layer to remove reliance on AWWS SDK classes

Danny Cranmer created FLINK-34339: - Summary: Add connector abstraction layer to remove reliance on AWWS SDK classes Key: FLINK-34339 URL: https://issues.apache.org/jira/browse/FLINK-34339 Project

[ANNOUNCE] Apache flink-connector-opensearch 1.1.0 released

The Apache Flink community is very happy to announce the release of Apache flink-connector-opensearch 1.1.0. This release supports Apache Flink 1.17 and 1.18. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data

[RESULT] [VOTE] flink-connector-opensearch v1.1.0, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 8 approving votes, 3 of which are binding: * Andriy Redko * Ahmed Hamdy * Ryan Skraba * Sergy Nuyanzin * Martijn Visser (binding) * Danny Cranmer (binding) * Jiabao Sun * Leonard Xu (binding

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

dated hashes > > - Verified signature > > - Verified tags > > - Verified no binaries in the source archive > > - Reviewed web pr and found that there're some conflicts need to be > resolved > > > > Best, > > Jiabao > > > > > >> 202

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

Thanks for driving this Leonard! +1 (binding) - Release notes look ok - Signatures/checksums of source archive are good - Verified there are no binaries in the source archive - Built sources locally successfully - v1.0.0-rc2 tag exists in github - Tag build passing on CI [1] - Contents of Maven

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

+1 (binding) - Release notes look good - Signatures match for binary/source archive - Checksums match for binary/source archive - Contents of Maven dist look complete - Verified there are no binaries in the source archive - Built src/tests pass running Maven locally - Tag is present in Github -

Re: [DISCUSS] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

+1 to removing LEGACY mode in Flink 2.0. Thanks for driving. Danny, On Sat, 13 Jan 2024, 08:20 Yanfei Lei, wrote: > Thanks Zakelly for starting this discussion. > > Regardless of whether it is for users or developers, deprecating > RestoreMode#LEGACY makes the semantics clearer and lower

[ANNOUNCE] Apache flink-connector-gcp-pubsub 3.0.2 released

this release possible! Best Regards Danny Cranmer

[RESULT][VOTE] flink-connector-gcp-pubsub v3.0.2, release candidate #2

I'm happy to announce that we have unanimously approved this release. There are 4 approving votes, 3 of which are binding: * Leonard Xu (binding) * Martijn Visser (binding) * Rui Fan * Danny Cranmer (binding) There are no disapproving votes. Thanks everyone! Danny

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

Thanks all, This vote is now closed, I will announce the results in a separate thread. Danny. On Fri, Jan 12, 2024 at 4:53 PM Danny Cranmer wrote: > +1 (binding) > > - Verified signatures and checksums > - Reviewed release notes > - Verified contents of Maven repo > - Ve

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

> > > > > > - built from source code succeeded > > > - verified signatures > > > - verified hashsums > > > - checked the contents contains jar and pom files in apache repo > > > - checked the lowest supported flink version issue has been f

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

Apologies I jumped the gun on this one. We only have 2 binding votes. Reopening the thread. On Fri, Jan 12, 2024 at 3:43 PM Danny Cranmer wrote: > Thanks all, this vote is now closed, I will announce the results on a > separate thread. > > Thanks, > Danny > > On Fri, Ja

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

inaries exist in the source archive > - Build the source with Maven > - Verified licenses > - Verified web PRs > > On Mon, Jan 1, 2024 at 11:57 AM Danny Cranmer > wrote: > > > > Hey, > > > > Gordon, apologies for the delay. Yes this is the correct unders

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

Thanks all, this vote is now closed, I will announce the results on a separate thread. Thanks, Danny On Fri, Jan 12, 2024 at 3:43 PM Danny Cranmer wrote: > +1 (binding) > > - Verified signatures and checksums > - Reviewed release notes > - Verified no binaries in the source arc

Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (binding) Thanks, Danny On Tue, Jan 9, 2024 at 9:31 AM Feng Jin wrote: > +1 (non-binding) > > Best, > Feng Jin > > On Tue, Jan 9, 2024 at 5:29 PM Yuxin Tan wrote: > > > +1 (non-binding) > > > > Best, > > Yuxin > > > > > > Márton Balassi 于2024年1月9日周二 17:25写道： > > > > > +1 (binding) > > > >

[DISCUSS] Externalized Python Connector Release/Dependency Process

Hello all, I have been working with Péter and Marton on externalizing python connectors [1] from the main repo to the connector repositories. We have the code moved and the CI running tests for Kafka and AWS Connectors. I am now looking into the release process. When we undertake a Flink release

[jira] [Created] (FLINK-34024) Update connector release process for Python connectors

Danny Cranmer created FLINK-34024: - Summary: Update connector release process for Python connectors Key: FLINK-34024 URL: https://issues.apache.org/jira/browse/FLINK-34024 Project: Flink

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

* Nexus has three staged artifact ids for 1.1.0-1.17 and 1.1.0-1.18 > > > - flink-connector-opensearch (.jar, -javadoc.jar, -sources.jar, > > > -tests.jar and .pom) > > > - flink-sql-connector-opensearch (.jar, -sources.jar and .pom) > > > - flink-connector-gcp-pubsub-pa

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

Hello, Thanks for driving, Leonard, +1 (binding) - Verified signatures and checksums of source and binaries - Maven dist contains expected files - There are no binaries in the source archive - Release notes look good - Tag exists in Github - CI passes for v4.1 [1] (could not find a tag build,

Re: [DISCUSS] Release Flink 1.18.1

+1 Thanks for driving this On Fri, 8 Dec 2023, 12:05 Timo Walther, wrote: > Thanks for taking care of this Jing. > > +1 to release 1.18.1 for this. > > Cheers, > Timo > > > On 08.12.23 10:00, Benchao Li wrote: > > I've merged FLINK-33313 to release-1.18 branch. > > > > Péter Váry

[ANNOUNCE] Apache flink-connector-aws 4.2.0 released

The Apache Flink community is very happy to announce the release of Apache flink-connector-aws 4.2.0. This release supports Flink 1.17 and 1.18. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[RESULT][VOTE] Release flink-connector-aws, v4.2.0 release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 7 approving votes, 3 of which are binding: * Mystic Lama * Danny Cranmer (binding) * Jiabao Sun * Martijn Visser (binding) * Ahmed Hamdy * Leonard Xu (binding) * Samrat Deb There are no disapproving votes. Thanks

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

Verified that no binaries exist in the source archive > > >> - Build the source with Maven > > >> - Verified licenses > > >> - Verified web PRs > > >> > > >> On Mon, Nov 20, 2023 at 12:29 PM Jiabao Sun > > >> wrote: >

Re: [DISCUSS] REST API behaviour when user main method throws error

a new set of client-facing APIs. > > I'm unaware of any framework that did this right (MR, Spark, etc had > the same issue); you must solve HA for drivers/client programs first. > > These are quick thoughts; something simple that works for 90% might be > worth pursuing, ignoring

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

Thanks for driving this release. +1 (binding) - Verified signatures and checksums - Verified there are no binaries in the source archive - Run simple Kinesis job on binary dist, verified consumer, map and print. The Flink dashboard looks good. - Built from source successfully - Contents of maven

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

ure > > On Tue, 31 Oct 2023 at 08:42, Danny Cranmer > wrote: > > > Hi everyone, > > > > Please review and vote on release candidate #1 for the version 4.2.0, as > > follows: > > [ ] +1, Approve the release > > [ ] -1, Do not approve the release (pleas

[VOTE] Release flink-connector-gcp-pubsub v3.0.2, release candidate #2

Hi everyone, Please review and vote on the release candidate #2 for the version 3.0.2 of flink-connector-gcp-pubsub, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which

[DISCUSS] REST API behaviour when user main method throws error

Hey all, We run Flink clusters in session mode; we upload the user jar and then invoke "/jars/:jarid/run" [1] REST API endpoint. We have noticed a discrepancy in the run endpoint and were hoping to get some feedback from the community before proposing a FLIP or Jira to fix it. Some problem

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

This vote is now closed due to the Flink version error in the pom reported by Leonard. Thanks all. On Thu, Nov 9, 2023 at 3:19 PM Martijn Visser wrote: > I agree with Leonard. We should also not update 1.16.0 to 1.18.0, but > to the lowest supported Flink version of this release (in this case,

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

Hey Leonard, Thanks for helping to verify the release. The 1.16.0 Flink version in the pom is a miss, ideally it should be updated to 1.18.0, additionally this should have been updated to 1.17.x previously. I would not consider it a hard blocker since the Maven build overrides this variable based

Re: Re:Re: [DISCUSS] Release 1.17.2

+1, thanks for picking this up. I am happy to help out with the bits you need PMC support for. Thanks, Danny On Tue, Nov 7, 2023 at 4:03 AM Yun Tang wrote: > Hi @casel.chen > > It seems FLINK-33365 is more related to JDBC connector than the Flink > runtime, and the

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

Hi everyone, Please review and vote on the release candidate #1 for the version 3.0.2 of flink-connector-pubsub, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: *

[VOTE] Release flink-connector-opensearch v1.1.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.1.0 of flink-connector-opensearch, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which

[DISCUSS] Connector releases for Flink 1.18

Hey all. Now Flink 1.18 is released we need to do some connector releases for integration parity. We can use this thread to start the discussions for each connector release and spawn separate vote threads. Kafka is done [1] (thanks Gordon) and AWS connectors are in process [2], I appreciate help

Re: [DISCUSS] AWS Connectors v4.2.0 release + 1.18 support

olunteers to release > rest external connectors for 1.18 support? > > Best, > Leonard > > > > 2023年10月31日 上午12:17，Tzu-Li (Gordon) Tai 写道： > > > > +1 > > > > On Mon, Oct 30, 2023 at 9:00 AM Danny Cranmer > > wrote: > > > >>

[VOTE] Release flink-connector-aws, v4.2.0 release candidate #1

Hi everyone, Please review and vote on release candidate #1 for the version 4.2.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], * the

[jira] [Created] (FLINK-33413) Bump Avro in AWS Connectors to address CVE-2023-39410

Danny Cranmer created FLINK-33413: - Summary: Bump Avro in AWS Connectors to address CVE-2023-39410 Key: FLINK-33413 URL: https://issues.apache.org/jira/browse/FLINK-33413 Project: Flink

[jira] [Created] (FLINK-33409) Bump Guava to address CVE-2020-8908/CVE-2023-2976

Danny Cranmer created FLINK-33409: - Summary: Bump Guava to address CVE-2020-8908/CVE-2023-2976 Key: FLINK-33409 URL: https://issues.apache.org/jira/browse/FLINK-33409 Project: Flink Issue

Re: [DISCUSS] AWS Connectors v4.2.0 release + 1.18 support

and > the 4.2.x series will correspond to Flink 1.18? > > Bests, > Samrat > > > On Mon, Oct 30, 2023 at 7:32 PM Jing Ge > wrote: > > > Hi Danny, > > > > +1 Thanks for driving it. Did you mean skip 4.1.1, since 4.1.0 has > already > > been

[DISCUSS] AWS Connectors v4.2.0 release + 1.18 support

Hello all, I would like to start the discussion to release Apache Flink AWS connectors v4.2.0. We released v4.1.0 over six months ago on 2023-04-03. Since then we have resolved 23 issues [1]. Additionally now Flink 1.18 is live we need to add support for this. I am proposing we skip 4.1.0 for

[jira] [Created] (FLINK-33279) KinesisStream e2e test failing on PR during cleanup

Danny Cranmer created FLINK-33279: - Summary: KinesisStream e2e test failing on PR during cleanup Key: FLINK-33279 URL: https://issues.apache.org/jira/browse/FLINK-33279 Project: Flink Issue

[jira] [Created] (FLINK-33260) Custom Error Handling for Kinesis Consumer

Danny Cranmer created FLINK-33260: - Summary: Custom Error Handling for Kinesis Consumer Key: FLINK-33260 URL: https://issues.apache.org/jira/browse/FLINK-33260 Project: Flink Issue Type

[jira] [Created] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

Danny Cranmer created FLINK-33151: - Summary: Prometheus Sink Connector - Create Github Repo Key: FLINK-33151 URL: https://issues.apache.org/jira/browse/FLINK-33151 Project: Flink Issue Type

Re: [VOTE] FLIP-312: Prometheus Sink Connector

+1 binding. Thanks for picking this up Lorenzo! Danny On Wed, 20 Sept 2023, 16:33 Jing Ge, wrote: > +1(binding) Thanks! > > Best regards, > Jing > > On Wed, Sep 20, 2023 at 3:20 PM Martijn Visser > wrote: > > > +1 (binding) > > > > Thanks for driving this. Cheers, M > > > > On Mon, Sep 18,

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

e AMP request signer be part of the connector or distributed as > a separate dependency? > > Regards > Lorenzo > > [1] https://prometheus.io/docs/concepts/remote_write_spec/#out-of-scope > > > On Mon, 18 Sept 2023 at 17:22, Danny Cranmer > wrote: > > > Thanks fo

Re: [VOTE] FLIP-307: Flink Connector Redshift

Thanks for driving this Samrat! +1 (binding) Thanks, Danny On Mon, Sep 18, 2023 at 4:17 AM Samrat Deb wrote: > Hi All, > > Thanks for all the feedback on FLIP-307: Flink Connector Redshift [1][2] > > I'd like to start a vote for FLIP-307. The vote will be open for at least > 72 > hours unless

Re: [DISCUSS] FLIP-307: Flink connector Redshift

aking progress towards creating the > >> POC. > >> > > >> > Bests, > >> > Samrat > >> > > >> > [1] > >> > > >> > > >> > https://docs.aws.amazon.com/redshift/latest/mgmt/jdbc20-download-driver.html > >>

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

Thanks for the reply Lorenzo. > Static credentials are just for the sake of the example. The current prototype implementation already uses DefaultAWSCredentialsProviderChain that supports static and dynamic credentials. We can make the credential provider configurable. The point here was that

Re: [VOTE] Apache Flink Stateful Functions Release 3.3.0, release candidate #2

+1 (binding) - Contents of dist matches 3.2.0 - Checksum/sigs of dist and maven repo match - Source archive does not contain any binaries - Reviewed the Docker PR - Reviewed website PR - Release notes look good - Tag is present in Github - Maven build+tests complete successfully - Verfied NOTICE

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

Hey Martijn, thanks for picking this up. +1 (binding) - Release notes look good - Sigs and checksums look good for source archive and Maven repo - Verified there are no binaries in the source archive - Tag exists in Github - Reviewed website PR - Contents of maven repo looks complete - Source

Re: [VOTE] Apache Flink Stateful Functions Release 3.3.0, release candidate #1

Hey Martijn, thanks for driving this. -1 (binding) due to the concerns highlighted below - NOTICE files are present - Note: The copyright year is out of data (2020) - Concern: we bundle AnchorJS (MIT) v3.1.0 and this is not listed in the NOTICE file - Concern: "statefun-sdk-java" bundles

  1   2   3   4   >