Congratulations!
Best,
Shawn Huang
Xuannan Su 于2024年3月19日周二 14:40写道：
> Congratulations! Thanks for all the great work!
>
> Best regards,
> Xuannan
>
> On Tue, Mar 19, 2024 at 1:31 PM Yu Li wrote:
> >
> > Congrats and thanks all for the efforts!
> >
> > Best Regards,
> > Yu
> >
> > On Tue, 19
Hi Xintong and Zakelly,
> 2. Regarding Strictly-ordered and Out-of-order of Watermarks
I agree with it that watermarks can use only out-of-order mode for
now, because there is still not a concrete example showing the
correctness risk about it. However, the strictly-ordered mode should
still be sup
Hi Yunfeng,
Thanks for the suggestion!
I will reorganize the FLIP-425 accordingly.
Best,
Zakelly
On Tue, Mar 19, 2024 at 3:20 PM Yunfeng Zhou
wrote:
> Hi Xintong and Zakelly,
>
> > 2. Regarding Strictly-ordered and Out-of-order of Watermarks
> I agree with it that watermarks can use only out
Wancheng Xiao created FLINK-34727:
-
Summary: RestClusterClient.requestJobResult throw
ConnectionClosedException when the accumulator data is large
Key: FLINK-34727
URL: https://issues.apache.org/jira/browse/FLINK-
Fei Feng created FLINK-34728:
Summary: operator does not need to upload and download the jar
when deploying session job
Key: FLINK-34728
URL: https://issues.apache.org/jira/browse/FLINK-34728
Project: Fli
LvYanquan created FLINK-34729:
-
Summary: "Core Concept" Pages for Flink CDC Chinese Documentation
Key: FLINK-34729
URL: https://issues.apache.org/jira/browse/FLINK-34729
Project: Flink
Issue Type
LvYanquan created FLINK-34730:
-
Summary: "Deployment" Page for Flink CDC Chinese Documentation
Key: FLINK-34730
URL: https://issues.apache.org/jira/browse/FLINK-34730
Project: Flink
Issue Type: S
Junrui Li created FLINK-34731:
-
Summary: Remove SpeculativeScheduler and incorporate its features
into AdaptiveBatchScheduler
Key: FLINK-34731
URL: https://issues.apache.org/jira/browse/FLINK-34731
Projec
Zhongqiang Gong created FLINK-34732:
---
Summary: Add document dead link check for Flink CDC Documentation
Key: FLINK-34732
URL: https://issues.apache.org/jira/browse/FLINK-34732
Project: Flink
zhuoshaojian created FLINK-34733:
Summary: OSS Filesystem throws ClassNotFoundException
Key: FLINK-34733
URL: https://issues.apache.org/jira/browse/FLINK-34733
Project: Flink
Issue Type: Bug
LvYanquan created FLINK-34734:
-
Summary: Update the titles for Chinese Documents.
Key: FLINK-34734
URL: https://issues.apache.org/jira/browse/FLINK-34734
Project: Flink
Issue Type: Sub-task
Hi Zakelly,
Thanks for your proposal. The FLIP looks good to me +1! I'd like to ask
some minor questions
I found that there is also a definition of class `FutureUtils` under `org.
apache. flink. util. concurrent` which seems to offer more interfaces. My
question is:
1. Is it possible for all `Fut
Hi everyone,
With the release announcement of Flink 1.19, it's a good time to kick off
discussion of the next release 1.20.
- Release managers
I'd like to volunteer as one of the release managers this time. It has been
good practice to have a team of release managers from different
backgrounds
Hi Yue,
Thanks for your comments!
1. Is it possible for all `FutureUtils` in Flink to reuse the same util
> class?
Actually, the `FutureUtils` here is a new util class that will share the
same package path with the `StateFuture`. Or I'd be fine renaming it
'StateFutureUtils'.
2. It seems that t
Hi Weijie,
Thanks for kicking off 1.20! I'd like to join you and participate in the
1.20 release.
Best,
Rui
On Tue, Mar 19, 2024 at 5:30 PM weijie guo
wrote:
> Hi everyone,
>
> With the release announcement of Flink 1.19, it's a good time to kick off
> discussion of the next release 1.20.
>
>
LvYanquan created FLINK-34735:
-
Summary: "Developer Guide - Understanding Flink CDC API" Page for
Flink CDC Chinese Documentation
Key: FLINK-34735
URL: https://issues.apache.org/jira/browse/FLINK-34735
Pr
LvYanquan created FLINK-34736:
-
Summary: "Deployment - Standalone" Page for Flink CDC Chinese
Documentation
Key: FLINK-34736
URL: https://issues.apache.org/jira/browse/FLINK-34736
Project: Flink
LvYanquan created FLINK-34737:
-
Summary: "Deployment - Kubernetes" Page for Flink CDC Chinese
Documentation
Key: FLINK-34737
URL: https://issues.apache.org/jira/browse/FLINK-34737
Project: Flink
Hi everyone,
Thanks for your valuable feedback!
Our discussions have been going on for a while and are nearing a
consensus. So I would like to start a vote after 72 hours.
Please let me know if you have any concerns, thanks!
Best,
Zakelly
On Tue, Mar 19, 2024 at 3:37 PM Zakelly Lan wrote:
>
LvYanquan created FLINK-34738:
-
Summary: "Deployment - YARN" Page for Flink CDC Chinese
Documentation
Key: FLINK-34738
URL: https://issues.apache.org/jira/browse/FLINK-34738
Project: Flink
Issue
Hi everyone,
Thanks for your valuable feedback!
The discussions were vibrant and have led to significant enhancements to
this FLIP. With this progress, I'm looking to initiate the voting in 72
hours.
Please let me know if you have any concerns, thanks!
Best,
Zakelly
On Tue, Mar 19, 2024 at 5:
Hi everyone,
Thanks for your valuable discussion and feedback!
Our discussions have been going on for a while and there have been no
new comments for several days. So I would like to start a vote after
72 hours.
Please let me know if you have any concerns, thanks!
Yanfei Lei 于2024年3月13日周三 12:5
Hi Jinzhong,
Thanks for the FLIP. I have the following questions:
1. Does Grouping Remote State Access only support asynchronous interfaces?
--If it is: IIUC, MultiGet can also greatly improve performance for
synchronous access modes. Do we need to support it ？
--If not, how can we disti
LvYanquan created FLINK-34739:
-
Summary: "Connectors" Page for Flink CDC Chinese Documentation
Key: FLINK-34739
URL: https://issues.apache.org/jira/browse/FLINK-34739
Project: Flink
Issue Type: S
LvYanquan created FLINK-34740:
-
Summary: "legacy-flink-cdc-sources" Pages for Flink CDC Chinese
Documentation
Key: FLINK-34740
URL: https://issues.apache.org/jira/browse/FLINK-34740
Project: Flink
LvYanquan created FLINK-34741:
-
Summary: "get-started" Page for Flink CDC Chinese Documentation
Key: FLINK-34741
URL: https://issues.apache.org/jira/browse/FLINK-34741
Project: Flink
Issue Type:
Hi everyone,
Thanks for your valuable feedback!
Our discussions have been going on for a while.
As a sub-FLIP of FLIP-423 which is nearing a consensus, I would like to
start a vote after 72 hours.
Please let me know if you have any concerns, thanks!
On Mon, Mar 11, 2024 at 11:48 AM Hangxiang Yu
Hi everyone,
Thanks for all the feedback, I'd like to start a vote on the FLIP-436:
Introduce Catalog-related Syntax [1]. The discussion thread is here
[2].
The vote will be open for at least 72 hours unless there is an
objection or insufficient votes.
[1]
https://cwiki.apache.org/confluence/di
LvYanquan created FLINK-34742:
-
Summary: Translate "FAQ" Page for Flink CDC Chinese Documentation
Key: FLINK-34742
URL: https://issues.apache.org/jira/browse/FLINK-34742
Project: Flink
Issue Type
Hi everyone,
Thanks for your discussion and feedback!
Our discussions have been going on for a while and there have been no new
concerns for several days. So I would like to start voting recently.
Best regards,
Weijie
Zakelly Lan 于2024年3月12日周二 17:40写道：
> Hi Weijie,
>
> Thanks for your reply
Hi Zakelly,
Thanks for bringing this discussion.
I'm +1 for the overall API design, except for one minor comment about the
name of StateIterator#onHasNext since I feel it is a little bit
unintuitive. Meanwhile, I asked the opinion from GPT, here's what it said
The prefix "on" is commonly used in
Hi Jane,
Thanks for your comments!
I guess there is no problem with the word 'on' in this scenario, since it
is an event-driven-like execution model. I think the word 'hasNext' may be
misleading since there is a 'hasNext' in a typical iterator which returns a
boolean for the existence of a next e
Hi,
since there are no more comments for a while, if there are no more comments for
another day, I will start a vote thread.
Thanks,
Ferenc
On Thursday, March 14th, 2024 at 11:20, Ferenc Csaky
wrote:
>
>
> Hi,
>
> Gentle ping to see if there are any other concerns or things that seems
>
Hi, Yubin
Thanks for driving it !
+1 non-binding.
Best,
Yuepeng Pan.
At 2024-03-19 17:56:42, "Yubin Li" wrote:
>Hi everyone,
>
>Thanks for all the feedback, I'd like to start a vote on the FLIP-436:
>Introduce Catalog-related Syntax [1]. The discussion thread is here
>[2].
>
>The
+1 (binding)
Best,
Jark
On Tue, 19 Mar 2024 at 19:05, Yuepeng Pan wrote:
> Hi, Yubin
>
>
> Thanks for driving it !
>
> +1 non-binding.
>
>
>
>
>
>
>
> Best,
> Yuepeng Pan.
>
>
>
>
>
>
>
>
> At 2024-03-19 17:56:42, "Yubin Li" wrote:
> >Hi everyone,
> >
> >Thanks for all the feedback, I'd like t
+1 (non-binding).
Best,
Ferenc
On Tuesday, March 19th, 2024 at 12:39, Jark Wu wrote:
>
>
> +1 (binding)
>
> Best,
> Jark
>
> On Tue, 19 Mar 2024 at 19:05, Yuepeng Pan panyuep...@apache.org wrote:
>
> > Hi, Yubin
> >
> > Thanks for driving it !
> >
> > +1 non-binding.
> >
> > Best,
>
+1 (non-binding)
Best,
Feng
On Tue, Mar 19, 2024 at 7:46 PM Ferenc Csaky
wrote:
> +1 (non-binding).
>
> Best,
> Ferenc
>
>
>
>
> On Tuesday, March 19th, 2024 at 12:39, Jark Wu wrote:
>
> >
> >
> > +1 (binding)
> >
> > Best,
> > Jark
> >
> > On Tue, 19 Mar 2024 at 19:05, Yuepeng Pan panyuep...@
Hi Yue,
Thanks for your feedback!
> 1. Does Grouping Remote State Access only support asynchronous interfaces?
>--If it is: IIUC, MultiGet can also greatly improve performance for
> synchronous access modes. Do we need to support it ？
Yes. If we want to support MultiGet on existing synchrono
Hi Yubin,
Big +1 for completing the catalog api!
There's a minor addition[1] which does not affect the vote could also be
considered.
[1] https://issues.apache.org/jira/browse/FLINK-21665
Best,
Lincoln Lee
Yubin Li 于2024年3月18日周一 17:44写道：
> Hi Jark,
>
> Thanks for your response, I have updat
+1 (binding)
Best,
Lincoln Lee
Feng Jin 于2024年3月19日周二 19:59写道：
> +1 (non-binding)
>
> Best,
> Feng
>
> On Tue, Mar 19, 2024 at 7:46 PM Ferenc Csaky
> wrote:
>
> > +1 (non-binding).
> >
> > Best,
> > Ferenc
> >
> >
> >
> >
> > On Tuesday, March 19th, 2024 at 12:39, Jark Wu wrote:
> >
> > >
>
Hi everyone,
This discussion has been open for a while and there are no new comments for
several days . As a sub-FLIP of FLIP-423 which is nearing a consensus, I
would like to start a vote after 72 hours.
Please let me know if you have any concerns, thanks!
Best,
Jinzhong
On Thu, Mar 7, 2024 a
Hi Hangxiang,
Thanks for bringing this discussion.
I have a few questions about the Proposal you mentioned in the FLIP.
The current conclusion is to use proposal 2, which is okay for me. My point
is whether we should retain the potential of proposal 1 in the design.
There are the following reason
Hi everyone,
Thanks for your valuable discussion and feedback!
Our discussions have been going on for a while. If there are no more
concerns, I would like to start the vote thread after 72 hours,thanks again!
Please let me know if you have any concerns, thanks!
Best,
Jinzhong
On Tue, Mar 19,
Rui Fan created FLINK-34743:
---
Summary: Memory tuning takes effect even if the parallelism isn't
changed
Key: FLINK-34743
URL: https://issues.apache.org/jira/browse/FLINK-34743
Project: Flink
Issue
+1(binding)
Best,
Leonard
> 2024年3月19日 下午9:03，Lincoln Lee 写道：
>
> +1 (binding)
>
> Best,
> Lincoln Lee
>
>
> Feng Jin 于2024年3月19日周二 19:59写道：
>
>> +1 (non-binding)
>>
>> Best,
>> Feng
>>
>> On Tue, Mar 19, 2024 at 7:46 PM Ferenc Csaky
>> wrote:
>>
>>> +1 (non-binding).
>>>
>>> Best,
>>
Hi Yun,
Thank you very much for your valuable input!
Incremental mode is indeed an attractive idea, we have also discussed
this, but in the current design,
we first provided two refresh modes: CONTINUOUS and
FULL. Incremental mode can be introduced
once the execution layer has the capability.
Hi Lincoln,
Good catch. Thanks for your suggestions.
I found that the creation statements of database and table both
support specifying "if not exists". For the sake of syntactic
consistency and user practicality, We could introduce the '[if not
exists]' clause to the 'create catalog' statement.
Rui Fan created FLINK-34744:
---
Summary: autoscaling-dynamic cannot run
Key: FLINK-34744
URL: https://issues.apache.org/jira/browse/FLINK-34744
Project: Flink
Issue Type: Bug
Components: Au
Hi Zakelly,
Thanks for your clarification. I'm +1 for using `onNext`.
Best,
Jane
On Tue, Mar 19, 2024 at 6:38 PM Zakelly Lan wrote:
> Hi Jane,
>
> Thanks for your comments!
>
> I guess there is no problem with the word 'on' in this scenario, since it
> is an event-driven-like execution model.
Hi Yubin,
Thanks for your quickly response!
It would be better to support comments just like create `database` and
`table` with comment.
That is, add `String getComment();` to the current `Catalog` interface.
WDYT?
Best,
Lincoln Lee
Yubin Li 于2024年3月19日周二 21:44写道：
> Hi Lincoln,
>
> Good catc
+1 (binding)
Best,
Jane
On Tue, Mar 19, 2024 at 9:30 PM Leonard Xu wrote:
> +1(binding)
>
>
> Best,
> Leonard
> > 2024年3月19日 下午9:03，Lincoln Lee 写道：
> >
> > +1 (binding)
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Feng Jin 于2024年3月19日周二 19:59写道：
> >
> >> +1 (non-binding)
> >>
> >> Best,
> >> Fen
Dawid Wysakowicz created FLINK-34745:
Summary: Parsing temporal table join throws cryptic exceptions
Key: FLINK-34745
URL: https://issues.apache.org/jira/browse/FLINK-34745
Project: Flink
Hi everyone,
Flink 1.19.0 has been officially released yesterday[1].
I'd like to share some highlights of the last release sync of 1.19:
- Remaining works
The official docker image is still in progress[2], will be available once
the related pr been merged[3].
In addition, some follow-up items a
Hi Lincoln,
Thanks for your detailed comments!
Supporting comments for `Catalog` is a really helpful feature, I agree
with you to make it introduced in this FLIP, thank you for pointing
that out :)
Concerning the implementation, I propose to introduce `getComment()`
method in `CatalogDescriptor`
Hello Flink Community,
We have a particular challenging scenario, which we’d like to run by the rest
of the community experts and check
1. If anything can be done with existing functionality that we’re overlooking,
or
2. The feasibility of this proposal.
I tried to keep it concise in a 1-pager
Hello Sergio,
I'm a newbie(not an expert) and give it a try.
If I presume you've only a reference state on Flink and no other states and
Kafka is the source, you may see below approach as an option , should test.
a. Create two applications - Primary and Secondary (blue and green)
b. Create two S3
Resending ->
Hello Sergio,
I'm a newbie(not an expert) and give it a try.
If I presume you've only a reference state on Flink and no other states and
Kafka is the source, you may see below approach as an option , should test.
a. Create two applications - Primary and Secondary (blue and green)
b.
Hi Max,
+1
- Verified SHA checksums
- Verified GPG signatures
- Verified that the source distributions do not contain binaries
- Verified built-in tests (mvn clean verify)
- Verified build with Java 11 (mvn clean install -DskipTests -T 1C)
- Verified that Helm and operator files contain Apache li
Hi Yubin,
Thank you for detailed explaination! I overlooked `CatalogBaseTable`, in
fact
there is already a `String getComment();` interface similar to `database`
and `table`.
Can we continue the work on FLINK-21665 and complete its implementation? It
seems to be very close.
Best,
Lincoln Lee
Y
Hi Yubin,
Sorry, please ignore my last reply (wrong context).
I also asked Leonard, your proposal to extend the `CatalogDescriptor`
should be okay.
Thank you for your update : ) !
Best,
Lincoln Lee
Lincoln Lee 于2024年3月20日周三 09:35写道：
> Hi Yubin,
>
> Thank you for detailed explaination! I ove
lincoln lee created FLINK-34746:
---
Summary: Switching to the Apache CDN for Dockerfile
Key: FLINK-34746
URL: https://issues.apache.org/jira/browse/FLINK-34746
Project: Flink
Issue Type: Improvem
Thanks for your continuous release sync summary, Lincoln. It help me a lot.
Best,
Leonard
> 2024年3月19日 下午11:49，Lincoln Lee 写道：
>
> Hi everyone,
>
> Flink 1.19.0 has been officially released yesterday[1].
>
> I'd like to share some highlights of the last release sync of 1.19:
>
> - Remai
Hi, Yubin,
I found a little mistake in FLIP.
`ALTER CATALOG catalog_name RESET (key1=val1, key2=val2, ...)` should be
changed as `ALTER CATALOG catalog_name RESET (key1, key2, ...)`, right?
Best,
Hang
Lincoln Lee 于2024年3月20日周三 10:04写道：
> Hi Yubin,
>
> Sorry, please ignore my last reply (wrong
+1 (non-binding)
Best,
Hang
Jane Chan 于2024年3月19日周二 22:02写道：
> +1 (binding)
>
> Best,
> Jane
>
> On Tue, Mar 19, 2024 at 9:30 PM Leonard Xu wrote:
>
> > +1(binding)
> >
> >
> > Best,
> > Leonard
> > > 2024年3月19日 下午9:03，Lincoln Lee 写道：
> > >
> > > +1 (binding)
> > >
> > > Best,
> > > Lincoln L
Hi, Yue.
Thanks for the reply.
If we use proposal1, we can easily reuse these optimizations .It is even
> possible to discuss and review the solution together in the Rocksdb
> community.
We also saw these useful optimizations which could be applied to ForSt in
the future.
But IIUC, it's not bindi
+1 (non-binding)
Best,
Zhongqiang Gong
Yubin Li 于2024年3月19日周二 18:03写道：
> Hi everyone,
>
> Thanks for all the feedback, I'd like to start a vote on the FLIP-436:
> Introduce Catalog-related Syntax [1]. The discussion thread is here
> [2].
>
> The vote will be open for at least 72 hours unless th
LvYanquan created FLINK-34747:
-
Summary: "legacy-flink-cdc-sources" Page of DB2 for Flink CDC
Chinese Documentation.
Key: FLINK-34747
URL: https://issues.apache.org/jira/browse/FLINK-34747
Project: Flink
Hi Hang,
I have updated FLIP as you suggested, thanks for your valuable feedback!
Best,
Yubin
On Wed, Mar 20, 2024 at 11:15 AM Hang Ruan wrote:
>
> Hi, Yubin,
>
> I found a little mistake in FLIP.
> `ALTER CATALOG catalog_name RESET (key1=val1, key2=val2, ...)` should be
> changed as `ALTER CAT
LvYanquan created FLINK-34748:
-
Summary: "legacy-flink-cdc-sources" Page of Oracle for Flink CDC
Chinese Documentation.
Key: FLINK-34748
URL: https://issues.apache.org/jira/browse/FLINK-34748
Project: Fli
LvYanquan created FLINK-34749:
-
Summary: "legacy-flink-cdc-sources" Page of SQLServer for Flink
CDC Chinese Documentation.
Key: FLINK-34749
URL: https://issues.apache.org/jira/browse/FLINK-34749
Project:
LvYanquan created FLINK-34750:
-
Summary: "legacy-flink-cdc-sources" Page of DB2 for Flink CDC
Chinese Documentation.
Key: FLINK-34750
URL: https://issues.apache.org/jira/browse/FLINK-34750
Project: Flink
Venkata krishnan Sowrirajan created FLINK-34751:
---
Summary: RestClusterClient APIs doesn't work with running Flink
application on YARN
Key: FLINK-34751
URL: https://issues.apache.org/jira/browse/FLINK
+1 (binding)
gongzhongqiang 于2024年3月20日周三 11:40写道：
>
> +1 (non-binding)
>
> Best,
> Zhongqiang Gong
>
> Yubin Li 于2024年3月19日周二 18:03写道：
>
> > Hi everyone,
> >
> > Thanks for all the feedback, I'd like to start a vote on the FLIP-436:
> > Introduce Catalog-related Syntax [1]. The discussion threa
Hi. Yubin.
Thanks for your update. LGTM.
Best,
Hang
Yubin Li 于2024年3月20日周三 11:56写道：
> Hi Hang,
>
> I have updated FLIP as you suggested, thanks for your valuable feedback!
>
> Best,
> Yubin
>
> On Wed, Mar 20, 2024 at 11:15 AM Hang Ruan wrote:
> >
> > Hi, Yubin,
> >
> > I found a little mista
74 matches
Mail list logo
