Congratuations - well deserved Sergey, I really appreciate your deep knowledge,
prolific contributions, support and community minded attitude,
Kind regards David.
From: Arvid Heise
Date: Monday, 7 April 2025 at 07:54
To: dev@flink.apache.org
Subject: [EXTERNAL] Re: [ANNOUNCE] New Apache Flink
Arvid Heise created FLINK-37622:
---
Summary: Exactly once Kafka sink does not produce any records in
batch mode
Key: FLINK-37622
URL: https://issues.apache.org/jira/browse/FLINK-37622
Project: Flink
+1, thanks @Arvid for driving this release!
Best,
Leonard
> 2025 4月 7 18:02，Tom Cooper 写道：
>
> +1 from me. Thanks for driving this.
>
> Is there anything I can do to help?
>
> Tom Cooper
> @tomcooper.dev | https://tomcooper.dev
>
>
> On Monday, 7 April 2025 at 08:54, Arvid Heise wrote:
>
Hi devs,
I'd like to start a discussion on FLIP-519: Introduce async lookup key
ordered mode[1].
The Flink system currently supports both record-level ordered and
unordered output modes for asynchronous lookup joins. However, it does
not guarantee the processing order of records sharing the same
Hi Daren thanks for the FLIP
Just a couple of questions and comments?
> Usable in both DataStream and Table API/SQL
What about python API? this is sth we should consider ahead since the
abstract element converter doesn't have a Flink type mapping to be used
from python, this is a issue we faced w
Hi Heise,
I agree with you. Let us push forward. I will review
https://github.com/apache/flink-connector-kafka/pull/154 and discuss it. I
will reply for some time because there seems to be too much code in this PR.
Best
Hongshun
On Mon, Apr 7, 2025 at 3:12 PM Arvid Heise wrote:
> Hi Hongshun,
Chirag Dewan created FLINK-37629:
Summary: Use Checkpointed Offset while migrating clusters in
DynamicKafkaSource
Key: FLINK-37629
URL: https://issues.apache.org/jira/browse/FLINK-37629
Project: Flink
+1 from me. Thanks for driving this.
Is there anything I can do to help?
Tom Cooper
@tomcooper.dev | https://tomcooper.dev
On Monday, 7 April 2025 at 08:54, Arvid Heise wrote:
> Hi folks,
>
> I would like to volunteer to drive the Kafka connector 4.0.0 release to
> make the connector finall
Hi everyone,
I'd like to start a vote on the FLIP-514: Custom Evaluator plugin for Flink
Autoscaler [1]. The discussion thread is here [2].
The vote will be open for at least 72 hours unless there is an objection or
insufficient votes.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLI
Zakelly Lan created FLINK-37623:
---
Summary: Async state support for `process()` in Datastream API
Key: FLINK-37623
URL: https://issues.apache.org/jira/browse/FLINK-37623
Project: Flink
Issue Ty
Zakelly Lan created FLINK-37624:
---
Summary: Support enableAsyncState and switch operator after
datastream transformation
Key: FLINK-37624
URL: https://issues.apache.org/jira/browse/FLINK-37624
Project: F
+1 (binding)
Gyula
On Mon, Apr 7, 2025 at 9:23 AM Pradeepta Choudhury
wrote:
> Hi everyone,
>
> I'd like to start a vote on the FLIP-514: Custom Evaluator plugin for
> Flink Autoscaler [1]. The discussion thread is here [2].
>
> The vote will be open for at least 72 hours unless there is an obj
+1(binding)
Best,
Rui
On Mon, Apr 7, 2025 at 3:25 PM Gyula Fóra wrote:
> +1 (binding)
>
> Gyula
>
> On Mon, Apr 7, 2025 at 9:23 AM Pradeepta Choudhury
> wrote:
>
> > Hi everyone,
> >
> > I'd like to start a vote on the FLIP-514: Custom Evaluator plugin for
> > Flink Autoscaler [1]. The discuss
+1 (binding)
I have verified:
- Checksum and signature
- There are no binaries in the source archive
- Release tag and staging jars
- Built from source
- Release notes and web PR
not a blocker: better update the NOTICE to year 2025
On Thu, Apr 3, 2025 at 2:12 PM weijie guo wrote:
> Hi ev
Gabor Somogyi created FLINK-37626:
-
Summary: Flaky test: ForStFlinkFileSystemTest.testSstFileInCache
Key: FLINK-37626
URL: https://issues.apache.org/jira/browse/FLINK-37626
Project: Flink
Iss
+1 (binding)
I have verified:
- Checksum and signature
- There are no binaries in the source archive
- Release tag and staging jars
- Built from source
- Release notes and web PR
Best,
Zakelly
On Thu, Apr 3, 2025 at 12:18 PM weijie guo
wrote:
> Hi everyone,
>
>
> Please review and vote
Hi Dev,
I would like to start a discussion about FLIP: Amazon CloudWatch Metric Sink
Connector
https://docs.google.com/document/d/1G2sQogV8S6M51qeAaTmvpClOSvklejjEXbRFFCv_T-c/edit?usp=sharing
This FLIP is proposing to add support for Amazon CloudWatch Metric sink in
flink-connector-aws repo. L
+1 (binding)
I have verified:
- Signatures and checksum
- There are no binaries in the source archive
- Release tag and staging jars
- Built from source
- Web PR and release notes
Best,
Zakelly
On Sat, Apr 5, 2025 at 11:22 PM Gyula Fóra wrote:
> +1 (binding)
>
> Verified:
> - Checkpo
Keith Lee created FLINK-37627:
-
Summary: Restarting from a checkpoint/savepoint which coincides
with shard split causes data loss
Key: FLINK-37627
URL: https://issues.apache.org/jira/browse/FLINK-37627
Pr
Congrats, Sergey!
Kind regards,
Gustavo
Am Do., 3. Apr. 2025 um 11:42 Uhr schrieb Shengkai Fang :
> Congratulations, Sergey!
>
> Best,
> Shengkai
>
> Xuyang 于2025年4月3日周四 16:19写道：
>
> > Cheers, Sergey!
> >
> >
> > --
> >
> > Best！
> > Xuyang
> >
> >
> >
> >
> >
> > 在 2025-04-03 15:58:48，
Congratulations Sergey! Well deserved.
Hong
On Mon, Apr 7, 2025 at 8:03 AM David Radley wrote:
> Congratuations - well deserved Sergey, I really appreciate your deep
> knowledge, prolific contributions, support and community minded attitude,
>
> Kind regards David.
>
> From: Arvid Heise
> Dat
Hi Arvid,
Thanks for the information. I think your plan makes sense given that we want to
get a Flink 2.0 compatible connector out ASAP.
I can keep updating my Kafka 4.0.0 PR [1] until we are ready to do the release
containing it. In my opinion version numbers are not a constrained resource and
Mika Naylor created FLINK-37625:
---
Summary: PyFlink Table API skips validation for Rows created with
positional arguments
Key: FLINK-37625
URL: https://issues.apache.org/jira/browse/FLINK-37625
Project:
23 matches
Mail list logo
