Hi.
> Let me give you a concrete example. The Gateway may use a Generic catalog
> implementation backed by a Database (where table properties would be
stored
> in a DB). This would be a common setup in different Flink services.
> In this model the catalog itself needs DB credentials while the runn
+ 1(binding)
Thanks for answering my concerns/questions.
Gyula
On Fri, Nov 8, 2024 at 11:16 AM Gyula Fóra wrote:
> Hey!
>
> Sorry, bit late to the party, I have added a concern to the discussion
> related to the gateway submission vote.
>
> I would like to clarify that before we close this vot
Hello Zakelly,
Thank you very much for your responses.
I was wondering:
I was thinking that we could have a migration utility:
1. You mention “However, manually specifying the operator ids can avoid this
problem.” I assume this is something we could add to the migration utility. Is
this an
Hi David,
I think the first task would be to test and collect what is not working
when migrating from 1.20 to 2.0-preview.
To see such issues in advance would be really awesome, since it would ease
the fixing/adaptation.
When we have such list we can discuss how severe are they and how to
address
Hello everyone,
I would like to have a kickoff meeting this week for us all to meet.
In general, I would like these meeting to be working meetings. But for this
first meeting I would like to discuss and agree:
* Goals
* Metrics
* Ongoing meeting structure and timing
I will collate
Hi Gabor,
That sounds very reasonable. I will put this on my list to try, hopefully in
the next few days.
I think the “operator UID and/or state processor API” are good strategies. If
we can identify those cases and socialise or provide a utility early that could
save a lot of pain during v2 ad
Hi Timo,
I'm +1 (non-binding) on the FLIP.
As a point of order, is the vote supposed to happen in a new thread?
Cheers,
Jim
On Mon, Nov 11, 2024 at 9:46 AM Konstantin Knauf wrote:
> +1 (binding)
>
> Am Mo., 11. Nov. 2024 um 15:20 Uhr schrieb Sergey Nuyanzin <
> snuyan...@apache.org>:
>
> > T
Thanks for this great improvement
+1 (binding)
On 2024/11/11 13:42:57 Timo Walther wrote:
> Hi everyone,
>
> I'd like to start a vote on FLIP-440: User-defined SQL operators /
> ProcessTableFunction (PTF) [1] which has been discussed in this thread [2].
>
> The vote will be open for at least 7
The Apache Flink community is very happy to announce the release of Apache
flink-connector-aws 5.0.0.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is available for download at:
+1 (binding)
Am Mo., 11. Nov. 2024 um 15:20 Uhr schrieb Sergey Nuyanzin <
snuyan...@apache.org>:
> Thanks for this great improvement
>
> +1 (binding)
>
> On 2024/11/11 13:42:57 Timo Walther wrote:
> > Hi everyone,
> >
> > I'd like to start a vote on FLIP-440: User-defined SQL operators /
> > Proc
+1(binding)
Best,
Ron
Gyula Fóra 于2024年11月12日周二 01:27写道:
> + 1(binding)
>
> Thanks for answering my concerns/questions.
>
> Gyula
>
> On Fri, Nov 8, 2024 at 11:16 AM Gyula Fóra wrote:
>
> > Hey!
> >
> > Sorry, bit late to the party, I have added a concern to the discussion
> > related to the g
Jason TANG created FLINK-36689:
--
Summary: [UI] Upgrade runtime web Angular framework and associated
deps to v15
Key: FLINK-36689
URL: https://issues.apache.org/jira/browse/FLINK-36689
Project: Flink
Thank you everyone for voting.
I'm closing the vote in another thread.
Thanks,
Hong
On Fri, Nov 8, 2024 at 10:36 AM Ahmed Hamdy wrote:
> Thanks Hong for driving,
> +1 (non-binding)
>
> - Release notes look good
> - Verified there are no blocker issues.
> - Verified signatures and hashsums
> -
I'm happy to announce that we have unanimously approved this release.
There are 4 approving votes, 3 of which are binding:
* Danny Cranmer (binding)
* Weijie Guo (binding)
* Xintong Song (binding)
* Ahmed Hamdy (non-binding)
There are no disapproving votes.
Thanks everyone!
Hey!
My point regarding the credentials wasn't about lazy/non-lazy catalog
initialization. The problem is that JM may run in an env where you don't
necessarily want to have the same credentials at all.
> I agree we need 2 different runners or designs here. But I don't think we
> should only suppo
Hi Alexis,
If you want to utilize the disaggregated state in Flink 2.0, you will need
to configure it to use the newly introduced ForSt Statebackend. We don't
support migrating states via checkpoints from one state backend to another.
However, it is possible to migrate state across state backends
Hi Zakelly,
For point 4, can you clarify two things:
- Is that incompatibility expected to be temporary, or will such a
migration never be possible?
- Will it be possible to configure the backend so that disaggregated state
is not used? I.e. keeping the current logic. And will this choice remain
Yanquan Lv created FLINK-36688:
--
Summary: table.optimizer.reuse-source-enabled may cause disordered
metadata columns when reading from Kafka.
Key: FLINK-36688
URL: https://issues.apache.org/jira/browse/FLINK-36688
Hi.
> My point regarding the credentials wasn't about lazy/non-lazy catalog
> initialization. The problem is that JM may run in an env where you don't
> necessarily want to have the same credentials at all.
Actually, a job requires same credentials to read the data or write data.
When compiling j
Hey!
> Actually, a job requires same credentials to read the data or write data.
> When compiling job in the job manager, we don't require extra credentials
You are making a lot of assumptions here regarding the catalog
implementations that are not generally true.
Let me give you a concrete examp
The Apache Flink community is very happy to announce the release of Apache
flink-connector-prometheus 1.0.0.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is available for downl
Thanks Fabian for your thorough review!
The FLIP is in a much better shape now. Thanks for all the feedback
everyone! I suggest we continue with voting if there are no objections.
This feature will be an iterative process anyway. So we will also be
able to digest initial user feedback later i
Hi everyone,
I'd like to start a vote on FLIP-440: User-defined SQL operators /
ProcessTableFunction (PTF) [1] which has been discussed in this thread [2].
The vote will be open for at least 72 hours unless there is an objection
or not enough votes.
[1]
https://cwiki.apache.org/confluence/
Thank you Timo for your response and the adjustments!
I have no further questions or comments.
So from my side I'm good to move forward with this FLIP.
Cheers, Fabian
On Fri, Nov 8, 2024 at 6:03 PM Timo Walther wrote:
> Hi David,
>
> happy to answer your questions as well:
>
> > 1. I wonder
Yanfei Lei created FLINK-36693:
--
Summary: Implement checkpoint for ForStSyncKeyedStateBackend
Key: FLINK-36693
URL: https://issues.apache.org/jira/browse/FLINK-36693
Project: Flink
Issue Type: S
+1 (non-binding)
--
Best!
Xuyang
在 2024-11-12 03:42:33,"Jim Hughes" 写道:
>Hi Timo,
>
>I'm +1 (non-binding) on the FLIP.
>
>As a point of order, is the vote supposed to happen in a new thread?
>
>Cheers,
>
>Jim
>
>On Mon, Nov 11, 2024 at 9:46 AM Konstantin Knauf wrote:
>
>> +1 (bind
yux created FLINK-36690:
---
Summary: Pipeline occasionally blocks when handling schema change
events in parallel
Key: FLINK-36690
URL: https://issues.apache.org/jira/browse/FLINK-36690
Project: Flink
Is
+1 (non-binding)
--
Best!
Xuyang
在 2024-11-12 10:02:27,"Ron Liu" 写道:
>+1(binding)
>
>Best,
>Ron
>
>Gyula Fóra 于2024年11月12日周二 01:27写道:
>
>> + 1(binding)
>>
>> Thanks for answering my concerns/questions.
>>
>> Gyula
>>
>> On Fri, Nov 8, 2024 at 11:16 AM Gyula Fóra wrote:
>>
>> > He
+1(binding)
Best,
Shengkai
Xuyang 于2024年11月12日周二 10:36写道:
> +1 (non-binding)
>
>
> --
>
> Best!
> Xuyang
>
>
>
>
>
> 在 2024-11-12 03:42:33,"Jim Hughes" 写道:
> >Hi Timo,
> >
> >I'm +1 (non-binding) on the FLIP.
> >
> >As a point of order, is the vote supposed to happen in a new thread?
>
Hi David,
I know finding a meeting time will be very hard; I am on the East coast of
the US.
Do you mean 11:30 AM or PM? (I assume AM.). If there are others in the US,
we can work async or maybe there could be separate meetings for different
goals.
In case I cannot attend, I'd like to suggest t
RocMarshal created FLINK-36691:
--
Summary: Support configuration to enable tasks balancing at slot
level for Default Scheduler
Key: FLINK-36691
URL: https://issues.apache.org/jira/browse/FLINK-36691
Proje
cris niu created FLINK-36692:
Summary: Flink Table HBase connector
Key: FLINK-36692
URL: https://issues.apache.org/jira/browse/FLINK-36692
Project: Flink
Issue Type: New Feature
Compone
32 matches
Mail list logo