Thanks for the summary!
Also +1 to support custom restart strategies in a different FLIP,
as long as we can make sure that the plugin interface won't be
changed when the restart strategy interface is introduced.
To achieve this, maybe we should think well how the handler
would cooperate with the
Thanks for driving this Ahmed. This change will benefit future and current
sink implementations by giving the developer more flexibility. A good
addition following configurable rate limiting strategies [1].
+1 (binding)
Thanks,
Danny
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-242
Here are a few things I noticed from the 1.17 release retrospectively which
I want to share (other release managers might have a different view or
might disagree):
- Google Meet might not be the best choice for the release sync. We need to
be able to invite attendees even if the creator of the mee
Thanks Konstantin for driving this.
I have no objections in regards to the feature freeze happening in July.
Thanks everyone for volunteering to drive 1.18. +1 on the people who
offered to help
PS: I shared learnings from the 1.17 release in the other thread [1] to not
spam this thread with 1.17-
Hi guys
Thanks for your enlightening opinions which have benefited me greatly. And I
have some experiences about configuring something on graphical IDE to share
with you. Hopefully, these experiences can give you some useful information.
At the FFA 2021, we proposed a solution for state migrati
Hi,
I am trying to understand how subtask distribution works in Flink. Let's
assume a setup of a Flink cluster with a fixed number of TaskManagers in a
kubernetes cluster.
Let's say I have a flink job with all the operators having the same
parallelism and with the same Slot sharing group. The ope
Fan Hong created FLINK-31623:
Summary: Improvements on DataStreamUtils#sample
Key: FLINK-31623
URL: https://issues.apache.org/jira/browse/FLINK-31623
Project: Flink
Issue Type: Improvement
João Boto created FLINK-31624:
-
Summary: [Connectors/Jdbc] Update flink to 1.17.0
Key: FLINK-31624
URL: https://issues.apache.org/jira/browse/FLINK-31624
Project: Flink
Issue Type: Improvement
Fan Hong created FLINK-31625:
Summary: Possbile OOM in KBinsDiscretizer
Key: FLINK-31625
URL: https://issues.apache.org/jira/browse/FLINK-31625
Project: Flink
Issue Type: Bug
Components
Weijie Guo created FLINK-31626:
--
Summary: HsSubpartitionFileReaderImpl should recycle skipped read
buffers.
Key: FLINK-31626
URL: https://issues.apache.org/jira/browse/FLINK-31626
Project: Flink
Matthias Pohl created FLINK-31627:
-
Summary: docker-build.sh build fails on Linux machines
Key: FLINK-31627
URL: https://issues.apache.org/jira/browse/FLINK-31627
Project: Flink
Issue Type: B
Dear Flinkers,
As you may have noticed, we are pleased to announce that Flink Table
Store has joined the Apache Incubator as a separate project called
Apache Paimon(incubating) [1] [2] [3]. The new project still aims at
building a streaming data lake platform for high-speed data ingestion,
change
Michael Helmling created FLINK-31628:
Summary: ArrayIndexOutOfBoundsException in watermark processing
Key: FLINK-31628
URL: https://issues.apache.org/jira/browse/FLINK-31628
Project: Flink
Hi,
1. Does this mean that each task slot will contain an entire pipeline in
> the job?
not exactly, each slot will run a subtask of each task. If the job is so
simple that
there is no keyby logic and we do not enable rebalance shuffle type, each
slot
could run all the pipeline. But if not we n
Weijie Guo created FLINK-31629:
--
Summary: Trying to access closed classloader when submit query to
restSqlGateway via SqlClient
Key: FLINK-31629
URL: https://issues.apache.org/jira/browse/FLINK-31629
Pro
Thanks for sharing that information.
Is there a specific workflow expected for pushing changes? Shall we always
go through the staging environment first or is it more like a nice-to-have
feature?
I'm also wondering whether we should move the documentation from the
Confluent page into the README f
Congratulations!
Best,
Leonard
> On Mar 27, 2023, at 5:23 PM, Yu Li wrote:
>
> Dear Flinkers,
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache Incubator as a separate project called Apache
> Paimon(incubating) [1] [2] [3]. The new projec
Congrats!
Best regards,
Jing
On Mon, Mar 27, 2023 at 2:32 PM Leonard Xu wrote:
> Congratulations!
>
>
> Best,
> Leonard
>
> On Mar 27, 2023, at 5:23 PM, Yu Li wrote:
>
> Dear Flinkers,
>
>
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache I
Congrats!
Am Mo., 27. März 2023 um 14:32 Uhr schrieb Leonard Xu :
> Congratulations!
>
>
> Best,
> Leonard
>
> On Mar 27, 2023, at 5:23 PM, Yu Li wrote:
>
> Dear Flinkers,
>
>
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache Incubator as a s
Congratulations and good luck with pushing the project forward.
On Mon, Mar 27, 2023 at 2:35 PM Jing Ge via user
wrote:
> Congrats!
>
> Best regards,
> Jing
>
> On Mon, Mar 27, 2023 at 2:32 PM Leonard Xu wrote:
>
>> Congratulations!
>>
>>
>> Best,
>> Leonard
>>
>> On Mar 27, 2023, at 5:23 PM, Y
Wow, that is good news! Thanks Chesnay for your effort.
I'd like to ask the same question as what Matthias asked. Speaking of the
workflow, should we first push changes to the asf-staging branch and check
it at https://flink.staged.apache.org and then cp them to the asf-site?
Should there always
congratulations 🥳
On Mon, 27 Mar 2023 at 6:02 PM, Leonard Xu wrote:
> Congratulations!
>
>
> Best,
> Leonard
>
> > On Mar 27, 2023, at 5:23 PM, Yu Li wrote:
> >
> > Dear Flinkers,
> >
> > As you may have noticed, we are pleased to announce that Flink Table
> Store has joined the Apache Incubato
congratulations!
Best regards,
Yuxia
发件人: "Andrew Otto"
收件人: "Matthias Pohl"
抄送: "Jing Ge" , "Leonard Xu" , "Yu Li"
, "dev" , "User"
, "user-zh"
发送时间: 星期一, 2023年 3 月 27日 下午 8:57:50
主题: Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache
Paimon(incubating)
Exciting!
Congrats Yu! Looking forward to contributing to Paimon!
Best Regards,
Xiangyu
yuxia 于2023年3月27日周一 21:01写道:
> congratulations!
>
> Best regards,
> Yuxia
>
>
> 发件人: "Andrew Otto"
> 收件人: "Matthias Pohl"
> 抄送: "Jing Ge" , "Leonard Xu" , "Yu
> Li" , "dev" , "User" <
> u...@flink.apache.org>, "user
Congratulations !!!
On Mon, Mar 27, 2023 at 2:54 PM Yu Li wrote:
> Dear Flinkers,
>
>
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache Incubator as a separate project called Apache
> Paimon(incubating) [1] [2] [3]. The new project still aim
Congratulations!
Best Regards,
Yanfei
ramkrishna vasudevan 于2023年3月27日周一 21:46写道:
>
> Congratulations !!!
>
> On Mon, Mar 27, 2023 at 2:54 PM Yu Li wrote:
>>
>> Dear Flinkers,
>>
>>
>> As you may have noticed, we are pleased to announce that Flink Table Store
>> has joined the Apache Incubator
It's just another tool in your belt. You can use it, but don't have to.
We used it for the Hugo migration, where we could only test some things
(like the rewrite rules) in a production-like environment.
I'm +0 on whether to move the docs to the repo or not.
On 27/03/2023 14:46, Jing Ge wrote:
congratulations
Bests,
Samrat
On Mon, Mar 27, 2023 at 7:19 PM Yanfei Lei wrote:
> Congratulations!
>
> Best Regards,
> Yanfei
>
> ramkrishna vasudevan 于2023年3月27日周一 21:46写道:
> >
> > Congratulations !!!
> >
> > On Mon, Mar 27, 2023 at 2:54 PM Yu Li wrote:
> >>
> >> Dear Flinkers,
> >>
> >>
> >
Great to see this, congratulations!
Best,
Alex
On Mon, 27 Mar 2023 at 11:24, Yu Li wrote:
> Dear Flinkers,
>
>
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache Incubator as a separate project called Apache
> Paimon(incubating) [1] [2] [3].
Thanks for the updates.
So far the above mentioned issues seem to all have PRs against
apache/flink-connector-kafka now.
To be clear, this notice isn't about discussing _what_ PRs we will be
merging or not merging - we should try to review all of them eventually.
The only reason I've made a list
congratulations
Bests,
Samrat
On Mon, 27 Mar 2023 at 8:24 PM, Alexander Fedulov <
alexander.fedu...@gmail.com> wrote:
> Great to see this, congratulations!
>
> Best,
> Alex
>
> On Mon, 27 Mar 2023 at 11:24, Yu Li wrote:
>
> > Dear Flinkers,
> >
> >
> >
> > As you may have noticed, we are pleased
Gyula Fora created FLINK-31630:
--
Summary: Support max-age for checkpoints during last-state upgrades
Key: FLINK-31630
URL: https://issues.apache.org/jira/browse/FLINK-31630
Project: Flink
Issue
Chris Nauroth created FLINK-31631:
-
Summary: Upgrade GCS connector to 2.2.11.
Key: FLINK-31631
URL: https://issues.apache.org/jira/browse/FLINK-31631
Project: Flink
Issue Type: Improvement
Hi,
Thank you so much for taking time to answer my questions and pointing me to
relevant documentation. Really appreciate it.
When the task failover happens, are there internal metrics in Flink at a
job level to track the new execution attempt? Is there a way for the
application owner to figure
Hi Jane,
Thanks for clarifying it. As far as I am concerned, the issue is where to
keep the user's job metadata, i.e. SQL script (to make the discussion
easier, let's ignore config). As long as FLIP-190 is only used for
migration/upgrade, SQL is the single source of truth. Once the compiled
plan h
Congratulations!
Best,
Shammon FY
On Mon, Mar 27, 2023 at 11:37 PM Samrat Deb wrote:
> congratulations
>
> Bests,
> Samrat
> On Mon, 27 Mar 2023 at 8:24 PM, Alexander Fedulov <
> alexander.fedu...@gmail.com> wrote:
>
> > Great to see this, congratulations!
> >
> > Best,
> > Alex
> >
> > On Mon
Hi Hongshun
Thanks for your answer.
I think the startup offset of Kafka such as timestamp or
specific_offset has no relationship with `Window Operator`. Users can
freely set the starting position according to their needs, it may be before
the latest Kafka data, or it may be at a certain point in
haishui created FLINK-31632:
---
Summary: watermark aligned idle source can't resume
Key: FLINK-31632
URL: https://issues.apache.org/jira/browse/FLINK-31632
Project: Flink
Issue Type: Bug
Co
Congratulations!
I believe Paimon will work with Flink to build the best streaming data
warehouse.
Best,
Jingsong
On Tue, Mar 28, 2023 at 8:27 AM Shammon FY wrote:
>
> Congratulations!
>
>
> Best,
> Shammon FY
>
> On Mon, Mar 27, 2023 at 11:37 PM Samrat Deb wrote:
>
> > congratulations
> >
> >
Congratulations!
Yu Li 于2023年3月27日周一 17:24写道:
>
> Dear Flinkers,
>
>
> As you may have noticed, we are pleased to announce that Flink Table
> Store has joined the Apache Incubator as a separate project called
> Apache Paimon(incubating) [1] [2] [3]. The new project still aims at
> building a stre
Congratulations!
Best,
Yu Zelin
> 2023年3月27日 17:23,Yu Li 写道:
>
> Dear Flinkers,
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache Incubator as a separate project called Apache
> Paimon(incubating) [1] [2] [3]. The new project still aims at
Congratulations!
Best,
Hang
yu zelin 于2023年3月28日周二 10:27写道:
> Congratulations!
>
> Best,
> Yu Zelin
>
> 2023年3月27日 17:23,Yu Li 写道:
>
> Dear Flinkers,
>
>
>
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the Apache Incubator as a separate project call
Congrats!
Thanks,
Biao /'bɪ.aʊ/
On Tue, 28 Mar 2023 at 10:29, Hang Ruan wrote:
> Congratulations!
>
> Best,
> Hang
>
> yu zelin 于2023年3月28日周二 10:27写道:
>
>> Congratulations!
>>
>> Best,
>> Yu Zelin
>>
>> 2023年3月27日 17:23,Yu Li 写道:
>>
>> Dear Flinkers,
>>
>>
>>
>> As you may have noticed, we
Congratulations!
Unlike other data-lakes, Paimon might be the first one to act as a stream-first
(not batch-first) data-lake.
Best
Yun Tang
From: Xianxun Ye
Sent: Tuesday, March 28, 2023 10:52
To: dev@flink.apache.org
Cc: Yu Li ; user ; user-zh
; dev@flink.apac
Congratulations!
Best,
Zhang Guanghui
Hang Ruan 于2023年3月28日周二 10:29写道:
> Congratulations!
>
> Best,
> Hang
>
> yu zelin 于2023年3月28日周二 10:27写道:
>
>> Congratulations!
>>
>> Best,
>> Yu Zelin
>>
>> 2023年3月27日 17:23,Yu Li 写道:
>>
>> Dear Flinkers,
>>
>>
>>
>> As you may have noticed, we are please
Hi Shammon,
Thanks a lot for your advise. I agree with your opinion now. It seems that
I forgot to consider that it may be at a certain point in the future.
I will modify OffsetsInitializer to provide a different strategy for later
discovered partitions, by which users can also customize strate
luoyuxia created FLINK-31633:
Summary: Hive dialect can't order by an unselected column
Key: FLINK-31633
URL: https://issues.apache.org/jira/browse/FLINK-31633
Project: Flink
Issue Type: Sub-task
Congratulations!
Best,
Yuxin
Guanghui Zhang 于2023年3月28日周二 11:06写道:
> Congratulations!
>
> Best,
> Zhang Guanghui
>
> Hang Ruan 于2023年3月28日周二 10:29写道:
>
> > Congratulations!
> >
> > Best,
> > Hang
> >
> > yu zelin 于2023年3月28日周二 10:27写道:
> >
> >> Congratulations!
> >>
> >> Best,
> >> Yu Zelin
Hi hongshun
Thanks for updating, the FLIP's pretty good and looks good to me!
Best,
Shammon FY
On Tue, Mar 28, 2023 at 11:16 AM Hongshun Wang
wrote:
> Hi Shammon,
>
>
> Thanks a lot for your advise. I agree with your opinion now. It seems that
> I forgot to consider that it may be at a certai
Yuxin Tan created FLINK-31634:
-
Summary: FLIP-301: Hybrid Shuffle supports Remote Storage
Key: FLINK-31634
URL: https://issues.apache.org/jira/browse/FLINK-31634
Project: Flink
Issue Type: New Fe
Exciting!
If this ends up working well, Wikimedia Foundation would love to try it out!
On Mon, Mar 27, 2023 at 8:39 AM Matthias Pohl via user <
u...@flink.apache.org> wrote:
> Congratulations and good luck with pushing the project forward.
>
> On Mon, Mar 27, 2023 at 2:35 PM Jing Ge via user
>
51 matches
Mail list logo