Xiqian YU created FLINK-35077:
-
Summary: Add package license check for Flink CDC modules.
Key: FLINK-35077
URL: https://issues.apache.org/jira/browse/FLINK-35077
Project: Flink
Issue Type:
Hi Muhammet,
Thanks for the suggestion. I updated the FLIP to include the options class.
Best regards,
Xuannan
On Wed, Apr 10, 2024 at 1:56 PM Muhammet Orazov
wrote:
>
> Hey Xuannan,
>
> Thanks for the FLIP and your efforts!
>
> Minor clarification from my side:
>
> > We will relocate these
Hi Zakelly,
Thanks for the comments. I updated the FLIP accordingly.
Best regards,
Xuannan
On Wed, Apr 10, 2024 at 11:12 AM Zakelly Lan wrote:
>
> Thanks Xuannan for driving this! +1 for cleaning these up.
>
> And minor comments: It seems the StateBackendOptions is already annotated
> with
Hey Rui,
+1 (non-binding).
Thanks for driving it!
Best,
Muhammet
On 2024-04-10 04:36, Rui Fan wrote:
Hi devs,
Thank you to everyone for the feedback on FLIP-441: Show
the JobType and remove Execution Mode on Flink WebUI[1]
which has been discussed in this thread [2].
I would like to start
Sorry for coming very late to this thread. I have not contributed much to
Flink publicly for quite some time but I have been involved with Flink,
daily, for years now and I'm keenly interested in where we take Flink SQL
going forward.
Thanks for the proposal!! I think it's definitely a step in
+1 (non-binding)
Best Regards
Ahmed Hamdy
On Wed, 10 Apr 2024 at 06:39, Zhu Zhu wrote:
> +1
>
> Thanks,
> Zhu
>
> gongzhongqiang 于2024年4月10日周三 13:11写道：
>
> > +1 (non binding)
> >
> >
> > Bests,
> >
> > Zhongqiang Gong
> >
> > Rui Fan <1996fan...@gmail.com> 于2024年4月10日周三 12:36写道：
> >
> > > Hi
Finally I published the POC of the minibatch for TopN function [1]. It
covers all the implementations of TopN functions because it buffers the
records before putting them to the collector inside AbstractTopNFunction.
For proving the performance optimization I used the nexmark q19 which was
Hi all,
I thought I'd cast my vote as well to give extra data:
1. Materialized Table
2. Materialized View (generally speaking I am not too concerned with
using a View here, but since there are concerns around updating a view I
put it second)
I think what is suggested in this FLIP is
elon_X created FLINK-35076:
--
Summary: Watermark alignment will cause data flow to experience
serious shake
Key: FLINK-35076
URL: https://issues.apache.org/jira/browse/FLINK-35076
Project: Flink
Jacky Lau created FLINK-35075:
-
Summary: Migrate TwoStageOptimizedAggregateRule
Key: FLINK-35075
URL: https://issues.apache.org/jira/browse/FLINK-35075
Project: Flink
Issue Type: Sub-task
Ryan Skraba created FLINK-35074:
---
Summary:
SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted
Key: FLINK-35074
URL: https://issues.apache.org/jira/browse/FLINK-35074
Hi,
I notice in the draft pr that there is a schema id in the format config. I was
wondering why? In the confluent avro and existing debezium formats, there is
no schema id in the config, but there is the ability to specify a complete
schema. In the protobuf format there is no schema id.
I
Julien Tournay created FLINK-35073:
--
Summary: Deadlock in LocalBufferPool when
NetworkBufferPool.internalRecycleMemorySegments is called concurrently
Key: FLINK-35073
URL:
Xiqian YU created FLINK-35072:
-
Summary: Doris pipeline sink does not support applying
AlterColumnTypeEvent
Key: FLINK-35072
URL: https://issues.apache.org/jira/browse/FLINK-35072
Project: Flink
Hongshun Wang created FLINK-35071:
-
Summary: Remove dependency on flink-shaded from cdc source
connector
Key: FLINK-35071
URL: https://issues.apache.org/jira/browse/FLINK-35071
Project: Flink
Thanks Xuannan for driving this proposal!
> Ensure all the ConfigOptions are properly annotated as PublicEvolving
Could we add a specification directly? All XxxOptions classes are
PublicEvolving by default. I'm afraid some new classes still miss
PublicEvolving in the future.
If we have a
16 matches
Mail list logo
