cnsky1103 created FLINK-37381:
-
Summary: Typo in Join document
Key: FLINK-37381
URL: https://issues.apache.org/jira/browse/FLINK-37381
Project: Flink
Issue Type: Bug
Components: Documen
The Apache Flink community is very happy to announce the release of
Apache Flink-shaded 20.0.
The flink-shaded project contains a number of shaded dependencies for
Apache Flink.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and acc
The next release sync will be held at the following time.
- 15:00, Feb 26, BJT (GMT+8)
- 08:00, Feb 26, CET (GMT+1)
- 23:00, Feb 25, PT (GMT-8)
Everyone is welcome to join via Google Meet [1]. The topics to be discussed
can be found at the Status / Follow-ups section of the release wiki page
[2].
Hongshun Wang created FLINK-37380:
-
Summary: Change TransactionalIdPrefix to a required option if
Exactly once in Kafka Connector
Key: FLINK-37380
URL: https://issues.apache.org/jira/browse/FLINK-37380
Zakelly Lan created FLINK-37379:
---
Summary: Lack of state cache load for ForSt after recovery
Key: FLINK-37379
URL: https://issues.apache.org/jira/browse/FLINK-37379
Project: Flink
Issue Type: B
slankka created FLINK-37378:
---
Summary: Yarn log aggregation fails with Kerberos DT issues
Key: FLINK-37378
URL: https://issues.apache.org/jira/browse/FLINK-37378
Project: Flink
Issue Type: Improvem
+1(binding)
Best regards,
Weijie
Zhanghao Chen 于2025年2月23日周日 16:36写道：
> +1 (non-binding)
>
> Thanks for driving this. It's a nice useability improvement for performing
> partial-updates on datalakes.
>
>
> Best,
> Zhanghao Chen
>
> From: xiangyu feng
> Sent:
Hi, Xiangyu
Thanks for the update.
+1 for the new interface name.
Best regards,
Weijie
Ron Liu 于2025年2月24日周一 19:25写道：
> Hi, Xiangyu
>
> Thanks for pinging me, the interface name looks good to me.
>
>
> Best,
> Ron
>
> xiangyu feng 于2025年2月24日周一 17:59写道：
>
>> Hi Lincoln,
>>
>> Thx for sugges
+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
+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)
> >
> > Thanks for working on this FLIP.
> >
> > Best regards,
> > Timo
> >
> > On 14.02.25 22:32, Alan She
Sergey Nuyanzin created FLINK-37377:
---
Summary: Sync guava with guava in flink-shaded
Key: FLINK-37377
URL: https://issues.apache.org/jira/browse/FLINK-37377
Project: Flink
Issue Type: Sub-t
Sergey Nuyanzin created FLINK-37376:
---
Summary: Bump flink-shaded to 20.0
Key: FLINK-37376
URL: https://issues.apache.org/jira/browse/FLINK-37376
Project: Flink
Issue Type: Bug
Com
Perhaps we should provide the Backward compatible version in the initial 2.0
release, and provided a deprecation plan for simplifying the code and only
supporting the newer Kryo 5.x in Flink 2.1+. This would be inline with the
previous decision provided in the FLIP's compatibility and deprecatio
+1 (binding)
Thank you,
Fabian
On Mon, Feb 24, 2025 at 12:32 PM Timo Walther wrote:
> +1 (binding)
>
> Thanks for working on this FLIP.
>
> Best regards,
> Timo
>
> On 14.02.25 22:32, Alan Sheinberg wrote:
> > Hi everyone,
> >
> > I'd like to start a vote on FLIP-491 [1]. It proposes
> > adding
Jufang He created FLINK-37375:
-
Summary: Checkpoint supports the Operator to customize
asynchronous snapshot state
Key: FLINK-37375
URL: https://issues.apache.org/jira/browse/FLINK-37375
Project: Flink
Thanks for chiming in Timo, I completely agree.
There seem to be 2 approaches available here:
1. Backward compatible: https://github.com/apache/flink/pull/22660
2. Non compatible https://github.com/apache/flink/pull/25896
They both seem to be feasible however the backward compatible approach is
m
Hi Gyula,
thanks for bringing this up. I agree that we should use one of the most
recent Kryo versions for Flink 2.0. Otherwise the community will suffer
again from incompatibilities and needs to wait for another major Flink
version. Thanks for starting this discussion. We should do it for 2.0
+1 (binding)
Thanks for working on this FLIP.
Best regards,
Timo
On 14.02.25 22:32, Alan Sheinberg wrote:
Hi everyone,
I'd like to start a vote on FLIP-491 [1]. It proposes
adding BundledAggregateFunction as an interface that aggregate function
UDFs can implement. The interface exposes a batc
Hi, Xiangyu
Thanks for pinging me, the interface name looks good to me.
Best,
Ron
xiangyu feng 于2025年2月24日周一 17:59写道：
> Hi Lincoln,
>
> Thx for suggestion.
>
> -- 1st, for the sql example in the Motivation part, why is cast nulls
> included in the select clause after union all multiple inputs
Hi everyone,
I would like to initiate a discussion for the FLIP-510[1] below, which aims
on optimising certain use cases in SQL which at the moment add
ChangelogNormalize, but don't necessarily need to do it.
Looking forward to hearing from you.
[1] https://cwiki.apache.org/confluence/x/7o5EF
Hi David!
Thanks for the feedback. This change has been already merged and was
relatively minor in the bigger scheme of things.
There is nothing conceptually binding the operator to Flink 1.x versions,
and it is naturally designed to be cross compatible.
Flink Operator 2.0 is not planned at the m
Hi,
I am not sure how the v2 preview would fit with 1.11. I would think we would
probably want to separate Flink v1 from a v2 operator. It seems strange to have
support for v2 even as a preview in a 3rd digit change like 1.11. Definitely +1
for a separate early v2 Flink operator and a separate F
Hi Lincoln,
Thx for suggestion.
-- 1st, for the sql example in the Motivation part, why is cast nulls
included in the select clause after union all multiple inputs?
I do have misplaced the CAST NULLs, revised in the FLIP[1].
-- 2nd, simplifying the multi partial-insert example, what would the
e
Thanks a lot to Dawid Wysakowicz
the issue was resolved!
I'm going to make an announce tomorrow after waiting 24 hours
as stated at the step Promote the release [1]
[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=85472039#Creatingaflinkshadedrelease-Promotetherelease
On Fr
Gustavo de Morais created FLINK-37374:
-
Summary: Support JSON built-in function for JSON_ARRAY
Key: FLINK-37374
URL: https://issues.apache.org/jira/browse/FLINK-37374
Project: Flink
Issue
Sergey Nuyanzin created FLINK-37373:
---
Summary: SplitFetcherManagerTest.testCloseFetcherWithException
keeps constantly failing
Key: FLINK-37373
URL: https://issues.apache.org/jira/browse/FLINK-37373
Gyula Fora created FLINK-37372:
--
Summary: Savepoint error can cause operator to hang
Key: FLINK-37372
URL: https://issues.apache.org/jira/browse/FLINK-37372
Project: Flink
Issue Type: Bug
27 matches
Mail list logo
