Thanks for driving this, Poorvank,
+1 (binding)
Thanks,
Danny
On Thu, Jun 12, 2025 at 7:19 AM Poorvank Bhatia
wrote:
> Hi everyone,
>
> I would like to start a vote on FLIP-533: Cassandra Sink V2
> <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-533%3A+Cassandra+Sink+V2
> >,
> which
Hello Daren,
Sounds good to me, +1 for the release. I can provide support on the steps
you do not have permission for.
The fixVersions are a bit of a mess in Jira. I see only 2 issues in v5.1.0
[1] and 19 issues in v4.4.0 [2], can you tidy this up?
Thanks,
Danny
[1]
https://issues.apache.org/ji
+1 (binding)
Thanks,
Danny
On Sat, 3 May 2025, 15:55 Daren Wong, wrote:
> Hi devs,
>
> A friendly ping if you could vote for this please? This is a new connector
> in addition to our existing connectors library which I believe benefits the
> Flink community and users, which I am excited about!
Thanks for driving this Poorvank.
+1 (binding)
Thanks,
Danny
On Wed, 12 Mar 2025, 11:48 Ahmed Hamdy, wrote:
> Thanks for addressing the feedback Poorvank,
>
> +1 (non-binding)
>
> Best Regards
> Ahmed Hamdy
>
>
> On Tue, 11 Mar 2025 at 11:32, Doğuşcan Namal
> wrote:
>
> > Thanks for the FLIP
Hello Poorvank,
Thanks for opening this discussion/FLIP. I am +1 for the idea, it seems
like a great enhancement to the AsyncSink.
Just one question/observation from me. We currently use a "Deque<..>
bufferedRequestEntries". Now we are exposing these batch creators; it might
not make sense to use
Hello Sergio,
Thankyou for starting this discussion, I have a few questions.
> having 2 identical pipelines running side-by-side
How do you ensure correctness between the 2 identical pipelines? For
example, processing time semantics or late data can result in different
outputs.
Some Sources have
Thanks for driving this release Arvid,
+1 (binding)
- Release notes look good
- Validated source archive signature & checksum
- Validated binary signature & checksum
- Verified no binaries in source archive
- Verified CI build of tag passed
- Verified contents of Maven repo. Nit: the URL should b
Thanks Hong for driving and addressing the issues in the previous release
candidate.
+1 (binding)
* Release notes look good
* Source archive signatures and checksums match
* There are no binaries in the source
* Build source using Maven
* Verified Apache headers exist and are correct in the new S
Thanks for driving this Hong (and Lorenzo), nice to see the new
connector launching.
+1 binding
- I note that the AWS SDK version differs between
flink-connector-prometheus [1] and flink-connector-aws [2]. This is
probably ok, but not ideal. We should find a strategy to align this in the
future t
7 interfaces.
> 2/ Breaking changes to the KDS source via Table and SQL API for the
> "flink-kinesis-connector" artifact (the old artifact).
>
> We are taking step (2) because the new KDS source has different
> configuration options compared to the old KDS source.
>
>
Thanks for driving this release Hong. I cannot find the discussion thread,
and was wondering what the justification is for a major release this time?
What are we breaking?
I will take a look at the release artifacts tomorrow.
Thanks,
Danny
On Tue, 5 Nov 2024, 08:06 Yanquan Lv, wrote:
> +1 (non
Hey Ahmed,
+1 for the release and you as release manager with PMC assistance.
Thanks for opening this discussion, we never finished releasing the
Elasticsearch connector for Flink 1.19 [1], so we do not have an official
version for Flink 1.19/1.20 which is a problem. I am happy to assist you as
s
Hey Arvid,
+1 (binding)
- I left a couple of comments on the website PR that need addressing
- Release notes look good
- Source archive signatures and checksums are correct
- There are no binaries in the source archive
- Contents of mvn dist look good
- Binary signatures and checksums are correct
Danny Cranmer created FLINK-36420:
-
Summary: Upgrade org.apache.avro:avro to 1.11.4
Key: FLINK-36420
URL: https://issues.apache.org/jira/browse/FLINK-36420
Project: Flink
Issue Type
Thanks for driving this Arvid.
+1 for the releases and the RM
For the 4.0.0 version it would be good to drop the Flink version from the
connector version (4.0.0, not 4.0.0-2.0). I started a discussion some time
ago [1], however the thread went stale. But I think the feedback was
generally aligned
+1 (binding)
Thanks,
Danny
On Fri, Sep 27, 2024 at 8:15 AM Arvid Heise wrote:
> +1 (binding),
>
> Best,
>
> Arvid
>
> On Tue, Sep 3, 2024 at 12:35 PM Saurabh Singh
> wrote:
>
> > Hi Flink Devs,
> >
> > Gentle Reminder for voting on FLIP-477: Amazon SQS Source Connector [1].
> > [1] https://cwi
Hello Saurabh,
Thanks for contributing this, I have seen multiple custom implementations
of SQS sources, so a community supported version will be a great addition.
// .setFailOnError(false)
A general callout that this is not ideal, I know we use it elsewhere but we
should consider some pluggable
: dev@flink.apache.org
> > > Subject: [EXTERNAL] RE: [DISCUSS] FLIP-XXX Apicurio-avro format
> > > Hi Danny,
> > > Thank you for your feedback on this.
> > >
> > > I agree that using maps has pros and cons. The maps are flexible, but
> do
> > > re
ve been little to
> no known issues in the last couple of releases? Would it be possible to
> verify that by running e2e tests of connector binaries built against an
> earlier Flink minor version against the latest Flink minor release
> candidate as part of the release?
>
> Tha
Hey Sergey,
I have completed the 3 tasks. Let me know if you need anything else.
Thanks,
Danny
On Tue, Jun 11, 2024 at 9:11 AM Danny Cranmer
wrote:
> Thanks for driving this Sergey, I will pick up the PMC tasks.
>
> Danny
>
> On Sun, Jun 9, 2024 at 11:09 PM Sergey Nuyanzin
&
Thanks for driving this Sergey, I will pick up the PMC tasks.
Danny
On Sun, Jun 9, 2024 at 11:09 PM Sergey Nuyanzin wrote:
> Hi everyone,
>
> as you might noticed the voting threads for release of flink-opensearch
> connectors (v1, v2) received 3+ binding votes[1][2]
>
> Now I need PMC help to
Hello Flink community,
It has been over 2 years [1] since we started externalizing the Flink
connectors to dedicated repositories from the main Flink code base. The
past discussions can be found here [2]. The community decided to
externalize the connectors to primarily 1/ improve stability and spe
Thanks for driving this Sergey.
+1 (binding)
- Release notes look good
- Source archive checksum and signature is correct
- Binary checksum and signature is correct
- Contents of Maven repo looks good
- Verified there are no binaries in the source archive
- Builds from source using Java 8 (-Popen
Thanks for driving this Sergey.
+1 (binding)
- Release notes look good
- Source archive checksum and signature is correct
- Binary checksum and signature is correct
- Contents of Maven repo looks good
- Verified there are no binaries in the source archive
- Builds from source using Java 11 (-Pope
The Apache Flink community is very happy to announce the release of Apache
flink-connector-kafka 3.2.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is
The Apache Flink community is very happy to announce the release of Apache
flink-connector-jdbc 3.2.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is a
I'm happy to announce that we have unanimously approved this release.
There are 9 approving votes, 3 of which are binding:
* Muhammet Orazov
* Ahmed Hamdy
* Hang Ruan
* Aleksandr Pilipenko
* Leonard Xu (binding)
* Fabian Paul
* Martijn Visser (binding)
* Yanquan Lv
* Danny Cranmer (bi
Thanks all. This vote is now closed, I will announce the results in a
separate thread.
On Fri, Jun 7, 2024 at 11:45 AM Danny Cranmer
wrote:
> +1 (binding)
>
> - Release notes look good
> - Source archive checksum and signature is correct
> - Binary checksum and signature is corre
t; - built from source code with java 8/11/17
> - checked Github release tag
> - checked the CI result
> - checked release notes
>
> Danny Cranmer 于2024年4月22日周一 21:56写道：
>
> > Hi everyone,
> >
> > Please review and vote on release candidate #1 for flink-connector-ka
Apologies, this was RC2, not RC1.
On Fri, Jun 7, 2024 at 11:12 AM Danny Cranmer
wrote:
> I'm happy to announce that we have unanimously approved this release.
>
> There are 7 approving votes, 3 of which are binding:
> * Ahmed Hamdy
> * Hang Ruan
> * Leonard Xu (b
I'm happy to announce that we have unanimously approved this release.
There are 7 approving votes, 3 of which are binding:
* Ahmed Hamdy
* Hang Ruan
* Leonard Xu (binding)
* Yuepeng Pan
* Zhongqiang Gong
* Rui Fan (binding)
* Weijie Guo (binding)
There was one -1 vote that was cancelled.
* Yuepen
> On Tue, Jun 4, 2024 at 1:31 PM gongzhongqiang >
> > wrote:
> >
> > > +1 (non-binding)
> > >
> > > - Validated checksum hash and signature.
> > > - Confirmed that no binaries exist in the source archive.
> > > - Built the so
The Apache Flink community is very happy to announce the release of Apache
flink-connector-cassandra 3.2.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release
I'm happy to announce that we have unanimously approved this release.
There are 6 approving votes, 3 of which are binding:
* Muhammet Orazov
* Ahmed Hamdy
* Hang Ruan
* Weijie Guo (binding)
* Leonard Xu (binding)
* Rui Fan (binding)
There are no disapproving votes.
Thanks,
Danny
> >
>> > >> +1 (non-binding)
>> > >>
>> > >> - Validated checksum hash
>> > >> - Verified signature
>> > >> - Verified that no binaries exist in the source archive
>> > >> - Build the source with Maven
ease possible!
Regards,
Danny Cranmer
I'm happy to announce that we have unanimously approved this release.
There are 7 approving votes, 3 of which are binding:
* Hang Ruan
* Ahmed Hamdy
* Aleksandr Pilipenko
* Leonard Xu (binding)
* Zhongqiang Gong
* Rui Fan (binding)
* Weijie Guo (binding)
There are no disapproving votes.
Thanks,
Fri, May 31, 2024 at 11:47 AM gongzhongqiang <
> gongzhongqi...@apache.org
> > >
> > wrote:
> >
> > > +1 (non-binding)
> > >
> > > - Validated the checksum hash and signature.
> > > - No binaries exist in the source archive.
&
The Apache Flink community is very happy to announce the release of Apache
flink-connector-gcp-pubsub 3.1.0 for Flink 1.18 and 1.19.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The releas
I'm happy to announce that we have unanimously approved this release.
There are 5 approving votes, 3 of which are binding:
* Ahmed Hamdy
* Hang Ruan
* Leonard Xu (binding)
* Rui Fan (binding)
* Danny Cranmer (binding)
There are no disapproving votes.
Thanks everyone!
This vote is now closed, I will announce the results on a separate thread.
Thanks all.
On Fri, Jun 7, 2024 at 10:10 AM Danny Cranmer
wrote:
> +1 (binding)
>
> - Release notes look good
> - Source archive checksum and signature is correct
> - Binary checksum and signa
aven 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)
ease possible!
Regards,
Danny Cranmer
I'm happy to announce that we have unanimously approved this release.
There are 6 approving votes, 3 of which are binding:
* Ahmed Hamdy
* Hang Ruan
* Jiabao Sun
* Qingsheng Ren (binding)
* Leonard Xu (binding)
* Danny Cranmer (binding)
There are no disapproving votes.
Thanks everyone!
Danny
This vote is now closed, I will announce the results in a new threaad
On Thu, Jun 6, 2024 at 10:43 AM Danny Cranmer
wrote:
> +1 (binding)
>
> - Release notes look good
> - Source archive checksum and signature is correct
> - Binary checksum and signature is correct
> - Cont
ure
> >>>> - 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,
> &g
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
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
15
> [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
>
>
>
>
>
>
>
>
>
>
>
>
>
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,
etc)
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 de
1]
> > >
> >
> 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
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, David
hing this!
> > >
> > > I can help with the HBase connector if necessary, will comment the
> > > details to the relevant Jira ticket.
> > >
> > > Best,
> > > Ferenc
> > >
> > >
> > >
> > >
> > > On Wednesday, April
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
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 r
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 yo
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
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 rev
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, opense
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 y
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
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 inclu
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,
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
>
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 3.2
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]
> https://i
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 inclu
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
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
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,
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
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
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
: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
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
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
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
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
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
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
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
29 AM Muhammet Orazov
> 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?
>>
>&
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 f
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
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. P
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
> >
>
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 2
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
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
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!
>
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,
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
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
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
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
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 streaming
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)
There a
ed 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
> >
> >
> >>
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 d
1 - 100 of 433 matches
Mail list logo
