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
+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
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
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
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-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
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-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
+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
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,
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, 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
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
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
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
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 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
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.
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
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
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`
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
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
+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
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
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.
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 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.
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.
+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,
>>
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
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,
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,
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
+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 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
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
+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...@
+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 (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
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
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 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 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 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
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 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
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
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:
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-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
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
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 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:
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!
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-34737:
-
Summary: "Deployment - Kubernetes" Page for Flink CDC Chinese
Documentation
Key: FLINK-34737
URL: https://issues.apache.org/jira/browse/FLINK-34737
Project: Flink
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-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
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.
>
>
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 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 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
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
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
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
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
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
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
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
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-
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
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
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
74 matches
Mail list logo
