Hi Zakelly,
Thank for the proposal! This makes it easy for Datastream (V1) users
to use async state processing.
Currently, only keyed states can use async state processing, could you
please add some examples about how `SingleOutputStreamOperator` use
async state processing?
Zakelly Lan 于2024年1
Thanks jiabao for picking up this release, + 1 for the release and RM candidate
from my side.
Plz feel free to ping me when you need help during your release process.
Best,
Leonard
> On Dec 11, 2024, at 11:58 AM, Jiabao Sun wrote:
>
> Hi,
>
> Since a long time has passed since the last dis
Hi,
Since a long time has passed since the last discussion thread[1]
and the addition of two new features during this period,
I have initiated a new discussion thread regarding the proposal
to create a release for flink-connector-mongodb 2.0.0 for Flink 1.20 and
1.19.
>From the last release (1.2.
+1 for a 1.20.1 release , best ~
David Radley 于2024年12月11日周三 00:07写道：
> +1 for a 1.20.1 release, Thanks for driving Alex!
>
> There is a PR [1] against master that fixes a lot of vulnerabilities in
> the Web UI, this requires a PR that brings in a later level of Node [2]. We
> would like to back
Ryan van Huuksloot created FLINK-36884:
--
Summary: GCS 503 Error Codes for `flink-checkpoints//shared/`
file after upload complete
Key: FLINK-36884
URL: https://issues.apache.org/jira/browse/FLINK-36884
+1 for a 1.20.1 release, Thanks for driving Alex!
There is a PR [1] against master that fixes a lot of vulnerabilities in the Web
UI, this requires a PR that brings in a later level of Node [2]. We would like
to backport these and have them part of the 1.20.1 release,
Kind regards, David.
[1] h
Hi Robert,
Have you asked ASF Infra?
>From a very quick look, it appears that the ASF Slack instance has old
messages. Infra may suggest that we use their instance. (Which doesn't
solve the history problem.)
Maybe Infra would know how they were able to get things set up?
Cheers,
Jim
On Tue,
+1 for a 1.20.1 release, Thanks for driving!
There was one issue[1] for which I have raised a fix PR[2] which I would like
to be included as part of this release. Please let me know if anything needs to
be done for this.
[1] https://issues.apache.org/jira/browse/FLINK-28897
[2] https://github.c
Hi all,
I just got an email that the content in the Apache Flink Slack will be
deleted soon.
I would like to avoid that, as there's a ton of very valuable content in
there (despite not being searchable as it is a free instance)
We do have this public archive of our Slack channel:
https://www.linen
Dawid Wysakowicz created FLINK-36883:
Summary: Views should keep the time attributes of the query
Key: FLINK-36883
URL: https://issues.apache.org/jira/browse/FLINK-36883
Project: Flink
Is
> It sounds like we are using this mechanism to cover all three cases. If
there is an appetite to do the first 2 in a more
> metadata driven way then I guess they would appear in the main scopes as
User Variables.
Yes, this FLIP will be re-using the pre-existing mechanism, so for example,
no chang
Wang Qilong created FLINK-36882:
---
Summary: Introduce MiniBatchGroupAggFunction in GroupAggregate
with Async State API
Key: FLINK-36882
URL: https://issues.apache.org/jira/browse/FLINK-36882
Project: Fli
Wang Qilong created FLINK-36881:
---
Summary: Introduce GroupTableAggFunction in GroupTableAggregate
with Async State API
Key: FLINK-36881
URL: https://issues.apache.org/jira/browse/FLINK-36881
Project: Fl
Hey, here's an up to date link (it should never expire)
https://join.slack.com/t/apache-flink/shared_invite/zt-1a38bf5ef-3vVs~mFteowuIwv7qL9ioA
On Sun, Dec 8, 2024 at 5:29 PM Vincent Stollenwerk
wrote:
> Hi everyone,
>
> I wanted to join the Apache Flink Slack server, however the invitation
>
Hi Hang,
Thankyou very much - just to confirm, are you willing to be the release
manager for the JDBC connector Flink 1.20 compatible release? If so, when are
you thinking of kicking this off.
Kind regards, David.
From: Peter Huang
Date: Tuesday, 10 December 2024 at 07:11
To: dev@flink.apache.
xuhuang created FLINK-36880:
---
Summary: Hybrid Shuffle support batch job recovery
Key: FLINK-36880
URL: https://issues.apache.org/jira/browse/FLINK-36880
Project: Flink
Issue Type: Improvement
Ruan Hang created FLINK-36879:
-
Summary: CDC yaml transform supports to convert delete as insert
Key: FLINK-36879
URL: https://issues.apache.org/jira/browse/FLINK-36879
Project: Flink
Issue Type:
Ruan Hang created FLINK-36878:
-
Summary: Shade kafka dependency in cdc yaml with the same path as
sql connector
Key: FLINK-36878
URL: https://issues.apache.org/jira/browse/FLINK-36878
Project: Flink
Yanquan Lv created FLINK-36877:
--
Summary: Kafka Sink output canal-json format of deleted record is
incorrect format.
Key: FLINK-36877
URL: https://issues.apache.org/jira/browse/FLINK-36877
Project: Flin
chenyuzhi created FLINK-36876:
-
Summary: Operator Heap Memory Leak
Key: FLINK-36876
URL: https://issues.apache.org/jira/browse/FLINK-36876
Project: Flink
Issue Type: Bug
Components: Kub
20 matches
Mail list logo
