+1 (binding)
Best,
Jark
On Wed, 21 May 2025 at 19:36, Gustavo de Morais
wrote:
> +1(non-binding).
>
> Thanks Xuyang,
> Gustavo
>
> On Tue 20. May 2025 at 09:44, Lincoln Lee wrote:
>
> > +1 (binding)
> >
> >
> > Best,
> > Lincoln Lee
> >
> >
> > 曹振 <15533273...@163.com> 于2025年5月20日周二 14:55写道：
>
Thanks to Xintong, Sean, and Chris for initiating this proposal.
I believe this is one of the most exciting FLIPs in the Flink community —
especially in the era of GenAI. It opens up great opportunities for Flink
to
evolve into a more intelligent and autonomous data processing system.
+1 for the
Thanks, Ron Liu for kicking off the 2.1 release.
+1 for Ron Liu to be the release manager and
+1 for the feature freeze date
Best,
Jark
On Mon, 24 Mar 2025 at 16:33, Ron Liu wrote:
> Hi everyone,
> With the release announcement of Flink 2.0, it's a good time to kick off
> discussion of the nex
Congratulations! And thanks to all who made this release possible!
Best,
Jark
On Tue, 25 Mar 2025 at 14:46, Jingsong Li wrote:
> Congratulations!
>
> Best,
> Jingsong
>
> On Tue, Mar 25, 2025 at 10:40 AM Yuan Mei wrote:
> >
> > Thanks for driving this & Congrats!
> >
> > Best
> > Yuan
> >
> >
+1 (binding)
- verified signatures: *OK*
- verified hashes: *OK*
- build source code with JDK11 and Maven 3.8.6: *OK*
- Started local cluster and verified web ui & logs: *OK*
- Run wordcount job: *OK*
Best,
Jark
On Thu, 13 Mar 2025 at 01:18, Ferenc Csaky
wrote:
> +1 (non-binding)
>
> - Verifie
+1 (binding)
- verified signatures: *OK*
- verified hashes: *OK*
- build source code with JDK11 and Maven 3.8.6: *OK*
- reviewed web PR
Best,
Jark
On Wed, 5 Feb 2025 at 10:14, Lincoln Lee wrote:
> +1 (binding)
>
> - verified hashes: OK
> - verified signatures: OK
> - build from source with JDK
+1 for externalizing hive connector
Best,
Jark
On Tue, 14 Jan 2025 at 10:01, Lincoln Lee wrote:
> Thanks Sergey for driving this important work!
>
> +1 for finishing the externalize.
>
>
> Best,
> Lincoln Lee
>
>
> Sergey Nuyanzin 于2025年1月14日周二 06:16写道：
>
> > Hi everyone,
> >
> > This is yet a
Jark Wu created FLINK-36736:
---
Summary: DynamicTableSink.Context#getTargetColumns should contains
all the columns that sink function will receive
Key: FLINK-36736
URL: https://issues.apache.org/jira/browse/FLINK-36736
Jark Wu created FLINK-36735:
---
Summary: SupportsRowLevelUpdate gives sink only the values of
required columns when specifying RowLevelUpdateInfo#requiredColumns
Key: FLINK-36735
URL: https://issues.apache.org/jira
+1 (binding)
- Build and compile the source code locally: *OK*
- Verified signatures and hashes: *OK*
- Reviewed the website release PR: *OK*
- Started local cluster and verified web ui & logs: *OK*
Bes,
Jark
On Thu, 17 Oct 2024 at 13:50, Jingsong Li wrote:
> +1 (binding)
>
> - Downloaded arti
Hi James,
After reading the comments in CALCITE-3094, I think what you are looking
for is the Flink code-splitting tools.
Code splitting is a common need for Java code generation and Flink has
extracted the code splitting into a
separate module "flink-table-code-splitter"[1] with little dependenci
I also think this should not block new feature development.
Having "nice-to-have" and "must-to-have" tags on the FLIPs is a good idea.
For the downstream projects, I think we need to release a 2.0 preview
version one or
two months before the formal release. This can leave some time for the
downstr
+1 (binding)
- Build and compile the source code locally: *OK*
- Verified signatures: *OK*
- Verified hashes: *OK*
- Checked no missing artifacts in the staging area: *OK*
- Reviewed the website release PR: *OK*
- Checked the licenses: *OK*
Best,
Jark
On Tue, 18 Jun 2024 at 18:14, Leonard Xu wr
Congratulations, Weijie!
Best,
Jark
On Tue, 4 Jun 2024 at 19:10, spoon_lz wrote:
> Congratulations, Weijie!
>
>
>
> Regards,
> Zhuo.
>
>
>
>
>
> Replied Message
> | From | Aleksandr Pilipenko |
> | Date | 06/4/2024 18:59 |
> | To | |
> | Subject | Re: [ANNOUNCE] New Apache Flink PMC
+1 (binding)
Best,
Jark
On Mon, 27 May 2024 at 14:29, Hang Ruan wrote:
> +1 (non-binding)
>
> Best,
> Hang
>
> gongzhongqiang 于2024年5月27日周一 14:16写道：
>
> > +1 (non-binding)
> >
> > Best,
> > Zhongqiang Gong
> >
> > Jane Chan 于2024年5月24日周五 09:52写道：
> >
> > > Hi all,
> > >
> > > I'd like to star
+1 (binding)
- checked signatures
- checked hashes
- checked release notes
- reviewed the release web PR
- checked the jars in the staging repo
- build and compile the source code locally with jdk8
Best,
Jark
On Wed, 15 May 2024 at 16:05, gongzhongqiang
wrote:
> +1 (non-binding)
>
> - Verified
Hi Jane,
Thanks for the proposal. +1 from my side.
Best,
Jark
On Thu, 16 May 2024 at 10:28, Xuannan Su wrote:
> Hi Jane,
>
> Thanks for driving this effort! And +1 for the proposed changes.
>
> I have one comment on the migration plan.
>
> For options to be moved to another module/package, I
+1 (binding)
Best,
Jark
On Thu, 9 May 2024 at 21:27, Lincoln Lee wrote:
> +1 (binding)
>
> Best,
> Lincoln Lee
>
>
> Feng Jin 于2024年5月9日周四 19:45写道：
>
> > +1 (non-binding)
> >
> >
> > Best,
> > Feng
> >
> >
> > On Thu, May 9, 2024 at 7:37 PM Xuyang wrote:
> >
> > > +1 (non-binding)
> > >
> > >
cat2 |
> > > | Type |
> > > generic_in_memory |
> > > | Comment |
> > > |
> > > | Properties | ('default-database','db'),
> > > ('type','
+1 (binding)
Best,
Jark
On Wed, 17 Apr 2024 at 20:52, Leonard Xu wrote:
> +1(binding)
>
> Best,
> Leonard
>
> > 2024年4月17日 下午8:31，Lincoln Lee 写道：
> >
> > +1(binding)
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Ferenc Csaky 于2024年4月17日周三 19:58写道：
> >
> >> +1 (non-binding)
> >>
> >> Best,
> >> Fe
Hi everyone,
On behalf of the PMC, I'm very happy to announce that Jing Ge has
joined the Flink PMC!
Jing has been contributing to Apache Flink for a long time. He continuously
works on SQL, connectors, Source, and Sink APIs, test, and document
modules while contributing lots of code and insightf
Hi everyone,
On behalf of the PMC, I'm very happy to announce that Lincoln Lee has
joined the Flink PMC!
Lincoln has been an active member of the Apache Flink community for
many years. He mainly works on Flink SQL component and has driven
/pushed many FLIPs around SQL, including FLIP-282/373/415/
iting operation happens only once at table
> > > >>>> creation.
> > > >>>> >> 3. For the framework, when we perform a certain kind of Alter
> > Table
> > > >>>> >> behavior for a table, for the table created b
+1 (binding)
Best,
Jark
On Tue, 2 Apr 2024 at 15:12, Timo Walther wrote:
> +1 (binding)
>
> Thanks,
> Timo
>
> On 29.03.24 17:30, Hao Li wrote:
> > Hi devs,
> >
> > I'd like to start a vote on the FLIP-437: Support ML Models in Flink
> > SQL [1]. The discussion thread is here [2].
> >
> > The v
Congratulations!
Best,
Jark
On Fri, 29 Mar 2024 at 12:08, Yun Tang wrote:
> Congratulations to all Paimon guys!
>
> Glad to see a Flink sub-project has been graduated to an Apache top-level
> project.
>
> Best
> Yun Tang
>
>
> From: Hangxiang Yu
> Sent: Friday,
Thanks, Hao,
Sounds good to me.
Best,
Jark
On Thu, 28 Mar 2024 at 01:02, Hao Li wrote:
> Hi Jark,
>
> I think we can start with supporting popular model providers such as
> openai, azureml, sagemaker for remote models.
>
> Thanks,
> Hao
>
> On Tue, Mar 26, 202
ld actually be deprecated. They got
> > >>> replaced by `getComment()` which is sufficient.
> > >>>
> > >>> 2) CREATE TEMPORARY MODEL is not supported.
> > >>>
> > >>> This is an unnecessary restriction. We should support temporary
>
Sorry, I mean we can bump the Calcite version if needed in Flink 1.20.
On Fri, 22 Mar 2024 at 22:19, Jark Wu wrote:
> Hi Timo,
>
> Introducing user-defined PTF is very useful in Flink, I'm +1 for this.
> But I think the ML model FLIP is not blocked by this, because we
> can
insightful comments.
> >
> > We have updated the proposal per our offline discussions:
> > 1. Model will be treated as a new relation in FlinkSQL.
> > 2. Include the common ML predict and evaluate functions into the open
> > source flink to complete the user journey.
> >
Thanks for kicking this off.
+1 for the volunteered release managers (Weijie Guo, Rui Fan) and the
targeting date (feature freeze: June 15).
Best,
Jark
On Fri, 22 Mar 2024 at 14:00, Rui Fan <1996fan...@gmail.com> wrote:
> Thanks Leonard for this feedback and help!
>
> Best,
> Rui
>
> On Fri
Congratulations and welcome!
Best,
Jark
On Thu, 21 Mar 2024 at 10:35, Rui Fan <1996fan...@gmail.com> wrote:
> Congratulations!
>
> Best,
> Rui
>
> On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan wrote:
>
> > Congrattulations!
> >
> > Best,
> > Hang
> >
> > Lincoln Lee 于2024年3月21日周四 09:54写道：
> >
> >
+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
nctions [2] which can operate on models. It's hard to specify
> all of them in model creation.
>
> [1]:
>
> https://cloud.google.com/bigquery/docs/reference/standard-sql/bigqueryml-syntax-predict
> [2]:
>
> https://cloud.google.com/bigquery/docs/reference/standard-sql/big
Congrats! Thanks Lincoln, Jing, Yun and Martijn driving this release.
Thanks all who involved this release!
Best,
Jark
On Mon, 18 Mar 2024 at 16:31, Rui Fan <1996fan...@gmail.com> wrote:
> Congratulations, thanks for the great work!
>
> Best,
> Rui
>
> On Mon, Mar 18, 2024 at 4:26 PM Lincoln Le
will reset the myKey attribute of a certain table to the default
> value. For catalogs,
> it might be better to use ALTER CATALOG xxx RESET ('mykey') for the sake of
> design
> consistency.
>
> WDYT? Looking forward to your suggestions.
>
> Best,
> Yubin
>
>>>> the
> > >> >>>>>> SQL parser implementation in the FLIP
> > >> >>>>>> for the SQL syntax might be a bit confusing. Also, the formal
> > >> >>>>>> definition
> > >>
en-us/sql/machine-learning/tutorials/quickstart-python-train-score-model?view=azuresqldb-mi-current
>
> Thanks,
> Hao
>
> On Wed, Mar 13, 2024 at 8:57 PM Jark Wu wrote:
>
> > Hi Mingge, Hao,
> >
> > Thanks for your replies.
> >
> > > PTF is ac
The pull request has been merged. Thank you for the discussion and
reviewing.
The page is live now: https://flink.apache.org/what-is-flink/special-thanks/
Best,
Jark
On Tue, 12 Mar 2024 at 17:44, Jark Wu wrote:
> I have created a JIRA issue and opened a pull request for this:
>
t for the provider.
>
> I think for the model functions, there are still dependencies or hacks we
> need to sort out as a built-in function. Maybe we can separate that as a
> follow up if we want to have it built-in and focus on the model syntax for
> this FLIP?
>
> Thanks,
>
K/FLIP-295%3A+Support+lazy+initialization+of+catalogs+and+persistence+of+catalog+configurations
> > > >
> > > > Best,
> > > > Jingsong
> > > >
> > > > On Wed, Mar 13, 2024 at 5:09 PM Yubin Li wrote:
> > > > >
> > > >
Hi Minge, Chris, Hao,
Thanks for proposing this interesting idea. I think this is a nice step
towards
the AI world for Apache Flink. I don't know much about AI/ML, so I may have
some stupid questions.
1. Could you tell more about why polymorphism table function (PTF) doesn't
work and do we have p
I have created a JIRA issue and opened a pull request for this:
https://github.com/apache/flink-web/pull/725.
Best,
Jark
On Tue, 12 Mar 2024 at 16:56, Jark Wu wrote:
> Thank you all for your feedback. If there are no other concerns or
> objections,
> I'm going to create a pull
Jark Wu created FLINK-34654:
---
Summary: Add "Special Thanks" Page on the Flink Website
Key: FLINK-34654
URL: https://issues.apache.org/jira/browse/FLINK-34654
Project: Flink
Issue Type: N
n Fri, Mar 8, 2024 at 11:55 AM Martijn Visser
> wrote:
> >
> > Hi all,
> >
> > I'm +1 on it. As long as we follow the ASF rules on this, we can thank
> > those that are/have made contributions.
> >
> > Best regards,
> >
> > Martijn
>
cture helps the Apache Flink project to run well. I
> > cannot imagine how insufficient CI machines would impact the development
> > progress, especially when the feature freeze date is close. And I believe
> > that most guys who contributed to the community would not know Alibaba
> an
gt; > > +1 and thanks for the proposal!
> > > >
> > > > Best regards,
> > > > Jing
> > > >
> > > > On Tue, Mar 5, 2024 at 10:26 AM tison wrote:
> > > >
> > > > > I like this idea, so +1 for setting up.
&g
Sorry, I posted the wrong [7] link. The Flink benchmark ML link is:
https://lists.apache.org/thread/bkw6ozoflgltwfwmzjtgx522hyssfko6
On Tue, 5 Mar 2024 at 16:56, Jark Wu wrote:
> Hi all,
>
>
>
> I want to propose adding a "Special Thanks" page to our Apache Flink we
Hi all,
I want to propose adding a "Special Thanks" page to our Apache Flink
website [1]
to honor and appreciate the companies and organizations that have sponsored
machines or services for our project. The establishment of such a page
serves as
a public acknowledgment of our sponsors' contrib
+1 (binding)
Best,
Jark
On Tue, 16 Jan 2024 at 18:01, Xuyang wrote:
> +1 (non-binding)
>
>
> --
>
> Best！
> Xuyang
>
>
>
>
>
> 在 2024-01-16 17:52:38，"Leonard Xu" 写道：
> >+1 (binding)
> >
> >Best,
> >Leonard
> >
> >> 2024年1月16日 下午5:40，Hang Ruan 写道：
> >>
> >> +1 (non-binding)
> >>
> >> B
+1 (binding)
Best,
Jark
On Tue, 9 Jan 2024 at 15:31, Benchao Li wrote:
> +1 (non-binding)
>
> Feng Wang 于2024年1月9日周二 15:29写道：
> >
> > +1 non-binding
> > Regards,
> > Feng
> >
> > On Tue, Jan 9, 2024 at 3:05 PM Leonard Xu wrote:
> >
> > > Hello all,
> > >
> > > This is the official vote whethe
Thanks Jing for driving this.
+1 (binding)
- Build and compile the source code locally: *OK*
- Verified signatures and hashes: *OK*
- Checked no missing artifacts in the staging area: *OK*
- Reviewed the website release PR: *OK*
- Went through the quick start: *OK*
* Started a cluster and ran t
Thanks Jing for driving 1.18.1.
+1 for this.
Best,
Jark
On Mon, 11 Dec 2023 at 16:59, Hong Liang wrote:
> +1. Thanks Jing for driving this.
>
> Hong
>
> On Mon, Dec 11, 2023 at 2:27 AM Yun Tang wrote:
>
> > Thanks Jing for driving 1.18.1 release, +1 for this.
> >
> >
> > Best
> > Yun Tang
> >
+1 for adding this to Apache Flink!
I think this can further extend the ability of Apache Flink and a lot of
users would be
interested to try this out.
Best,
Jark
On Thu, 7 Dec 2023 at 12:06, Samrat Deb wrote:
> That's really cool :)
> +1 for the great addition
>
> Bests,
> Samrat
>
> On Thu,
Jark Wu created FLINK-33600:
---
Summary: Print cost time for batch queries in SQL Client
Key: FLINK-33600
URL: https://issues.apache.org/jira/browse/FLINK-33600
Project: Flink
Issue Type: New
+1 (binding)
Best,
Jark
On Thu, 16 Nov 2023 at 12:41, Leonard Xu wrote:
> +1(binding)
>
> Best,
> Leonard
>
> > 2023年11月16日 下午12:13，Mingliang Liu 写道：
> >
> > +1 (non-binding)
> >
> > On Wed, Nov 15, 2023 at 3:38 PM Peter Huang
> > wrote:
> >
> >> Hi Devs,
> >>
> >> I'd like to start a vote on
+1
I think we can mark the temporary config option as deprecated when we
introduce it.
So we can remove it after 2 minor releases (1.19, 1.20), i.e., drop in 2.0
release.
A minor comment about the config option, I would suggest to use
"avro.timestamp-mapping.legacy"
instead of "avro.timestamp_map
> >> Timo
> >>
> >>
> >> On 30.10.23 10:44, Timo Walther wrote:
> >>> Hi Jark,
> >>>
> >>> my intention was to avoid too complex syntax in the first version. In
> >>> the past years, we could enable use cases als
+1 for the proposed release managers and feature freeze on Jan 26
sounds good to me.
Best.
Jark
On Mon, 30 Oct 2023 at 12:15, Xintong Song wrote:
> Thanks for kicking this off.
>
> +1 for the proposed release managers (Lincoln, Yun, Jing and Martijn) and
> targeting date (feature freeze: Jan 2
s a
> SupportsXXXPushDown interface, the optimizer should push the corresponding
> predicates to the Source. I am not sure in which case this configuration
> would be used. Any ideas @Jark Wu ?
>
> Thanks,
>
> Jiangjie (Becket) Qin
>
>
> On Wed, Oct 25, 2023 at 11:55 PM
Hi Timo,
Thanks for starting this discussion. I really like it!
The FLIP is already in good shape, I only have some minor comments.
1. Could we also support HASH and RANGE distribution kind on the DDL
syntax?
I noticed that HASH and UNKNOWN are introduced in the Java API, but not in
the syntax.
Congratulations and thanks release managers and everyone who has
contributed!
Best,
Jark
On Fri, 27 Oct 2023 at 12:25, Hang Ruan wrote:
> Congratulations!
>
> Best,
> Hang
>
> Samrat Deb 于2023年10月27日周五 11:50写道：
>
> > Congratulations on the great release
> >
> > Bests,
> > Samrat
> >
> > On Fri
+1 (binding)
Best,
Jark
On Wed, 25 Oct 2023 at 16:27, Jiabao Sun
wrote:
> Thanks Jane for driving this.
>
> +1 (non-binding)
>
> Best,
> Jiabao
>
>
> > 2023年10月25日 16:22，Lincoln Lee 写道：
> >
> > +1 (binding)
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Zakelly Lan 于2023年10月23日周一 14:15写道：
> >
> >>
>>>
> >>>> Thanks Jark,
> >>>>
> >>>> If we only add configuration without adding the enableFilterPushDown
> >>>> method in the SupportsFilterPushDown interface,
> >>>> each connector would have to handle the same logic in the appl
Hi JIabao,
I think the current interface can already satisfy your requirements.
The connector can reject all the filters by returning the input filters
as `Result#remainingFilters`.
So maybe we don't need to introduce a new method to disable
pushdown, but just introduce an option for the specific
oject was in
the early days.
Please join me in congratulating Jane Chan for becoming a Flink Committer!
Best,
Jark Wu (on behalf of the Flink PMC)
join me in congratulating Ron Liu for becoming a Flink Committer!
Best,
Jark Wu (on behalf of the Flink PMC)
you have time to comment on whether the current design looks good?
>
> I plan to start voting in 3 days if there is no follow-up comment.
>
> Thanks,
> Dong
>
>
> On Fri, Sep 15, 2023 at 2:01 PM Jark Wu wrote:
>
> > Hi Dong,
> >
> > > Note that we can
html#GUID-D62CA6D8-D0D8-4A20-93EA-EEB4B3144347
> [2]
>
> https://www.mssqltips.com/sqlservertip/4175/disabling-sql-server-optimizer-rules-with-queryruleoff/
>
> Best regards,
>
> Martijn
>
> On Fri, Sep 15, 2023 at 10:53 AM Jark Wu wrote:
>
> > Hi Martijn,
> >
t; > Hi Jing and Jark!
> >
> > I can definitely appreciate the desire to have fewer configurations.
> >
> > Do you have a suggested alternative for platform providers to limit or
> > restrict the hints that Bonnie is talking about?
> >
> > As on
cklog(false)" first, but the watermark
lag
exceeds the configured value.
This is the conflict I'm concerned about.
Best,
Jark
On Fri, 15 Sept 2023 at 12:00, Dong Lin wrote:
> Hi Jark,
>
> Please see my comments inline.
>
> On Fri, Sep 15, 2023 at 10:35 AM Jark Wu wr
r this right
> now), we can add such a config in the future with a follow-up FLIP. The
> job-level config will still be useful as it makes users' configuration
> simpler for common scenarios.
>
> If it is OK, can we agree to make incremental progress for Flink and start
Sun, 10 Sept 2023 at 19:44, Dong Lin wrote:
> Hi Jark,
>
> Thanks for the comments. Please see my comments inline.
>
> On Sat, Sep 9, 2023 at 4:13 PM Jark Wu wrote:
>
> > Hi Xuannan,
> >
> > I leave my comments inline.
> >
> > > In the case where a
way, I feel hints could be sometimes confusing for users
> because
> > > most
> > > > >> of them have no effect for streaming and long-term we could also
> set
> > > > >> some hints via the CompiledPlan. And if you have multiple teams,
> > >
t; >>>>>>>>
> > >>>>>>>> Best,
> > >>>>>>>> Xuannan
> > >>>>>>>>
> > >>>>>>>> [1]
> > >>>>>>>>
> > >
+1 to fix it first.
I also agree to deprecate it if there are few people using it,
but this should be another discussion thread within dev+user ML.
In the future, we are planning to introduce user-defined-operator
based on the TVF functionality which I think can fully subsume
the UDTAG, cc @Timo
gt; > > > > define
> > > > > >>>> watermarks. However, after considering the
> pending-record-based
> > > > > >> solution, I
> > > > > >>>> believe the current solution is superior for the target use
> case
> > > as it
&g
Thank you all for helping with the roadmap documentation.
I have merged the roadmap pull request.
Cheers,
Jark
On Wed, 23 Aug 2023 at 15:26, Jing Ge wrote:
> Thanks Jark, +1 for the OLAP :-)
>
> Best regards,
> Jing
>
> On Sun, Aug 20, 2023 at 5:04 PM Jark Wu wrote:
>
+1 (binding)
Best,
Jark
> 2023年8月30日 02:40，Venkatakrishnan Sowrirajan 写道：
>
> Hi everyone,
>
> Thank you all for your feedback on FLIP-356. I'd like to start a vote.
>
> Discussion thread:
> https://lists.apache.org/thread/686bhgwrrb4xmbfzlk60szwxos4z64t7
> FLIP:
> https://cwiki.apache.org/co
+1 (binding)
Best,
Jark
> 2023年8月31日 18:54，Jing Ge 写道：
>
> +1(binding)
>
> On Thu, Aug 31, 2023 at 11:22 AM Sergey Nuyanzin
> wrote:
>
>> +1 (binding)
>>
>> On Thu, Aug 31, 2023 at 9:28 AM Benchao Li wrote:
>>
>>> +1 (binding)
>>>
>>> Martijn Visser 于2023年8月31日周四 15:24写道：
+1
xArray* we can just do away with *fieldNames *array that
> includes fieldName at every level for the nested field.
>
> Updated the FLIP-357
> <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-356%3A+Support+Nested+Fields+Filter+Pushdown
> >
> wiki as well.
>
>
> the method *applyFilters.
> > > > > >
> > > > > > 3. Finally, I think we need to look at the costs and benefits of
> > unifying
> > > > > > the SupportsFilterPushDown and SupportsProjectionPushDown (or
>
le. Or we have to introduce two different
> applyProjections()
> > methods for FieldReferenceExpression / NestedFieldReferenceExpression
> > respectively. This issue further extends to implementation in addition to
> > public API. A single FieldReferenceExpression might help sim
ive. Given the size of Flink, keeping APIs in the same style over
> time is important. The migration is also not that complicated.
>
> Thanks,
>
> Jiangjie (Becket) Qin
>
>
> On Tue, Aug 22, 2023 at 2:23 PM Jark Wu wrote:
>
> > Hi Venkat,
> >
> > Thanks for
Hi Venkat,
Thanks for the proposal.
I have some minor comments about the FLIP.
1. I think we don't need to
add SupportsFilterPushDown#supportsNestedFilters() method,
because connectors can skip nested filters by putting them in
Result#remainingFilters().
And this is backward-compatible because u
Hi Xuannan,
Thanks for opening this discussion.
This current proposal may work in the mentioned watermark cases.
However, it seems this is not a general solution for sources to determine
"isProcessingBacklog".
>From my point of view, there are 3 limitations of the current proposal:
1. It doesn't
lve you and Xingtong
> > on the document after updating.
> >
> > Best,
> > Shammon FY
> >
> >
> > On Mon, Aug 14, 2023 at 10:39 PM Jark Wu wrote:
> >
> >> Hi Shammon,
> >>
> >> Sure, could you help to draft a subsection about t
for example):
> >>>
> >>> 1. system columns provided by external systems via catalogs, such
> >>> as ROWID from the original system.
> >>> 2. system columns generated by Flink, such as ROWID generated by
> >>> Flink itself.
>
Sorry, I still don't understand why we need to disable the query hint.
It doesn't have the security problems as options hint. Bonnie said it
could affect performance, but that depends on users using it explicitly.
If there is any performance problem, users can remove the hint.
If we want to disabl
Song, could we add a subsection in `Towards Streaming Warehouses`
> or `Performance` that the short-lived query in Flink Session Cluster is one
> of the future directions for Flink?
>
> Best,
> Shammon FY
>
> On Mon, Aug 14, 2023 at 8:03 PM Jark Wu <mailto:imj...@gm
Hi Becket,
> I kind of think that we can
restrain the scope to just batch mode, and only for StreamRecord class.
That means only in batch mode, the timestamp in the StreamRecord will be
dropped when the config is enabled.
However, IIUC, dropping timestamp in StreamRecord has been supported.
This
ond a bit late.
> >
> > I will put a draft for the long-term vision for the state as well as
> > large-scale state support into the roadmap.
> >
> > Best
> > Yuan
> >
> > On Mon, Jul 17, 2023 at 10:34 AM Jark Wu wrote:
> >
> >> Hi J
Congratulations, Weihua!
Best,
Jark
On Fri, 4 Aug 2023 at 14:48, Yuxin Tan wrote:
> Congratulations Weihua!
>
> Best,
> Yuxin
>
>
> Junrui Lee 于2023年8月4日周五 14:28写道：
>
> > Congrats, Weihua!
> > Best,
> > Junrui
> >
> > Geng Biao 于2023年8月4日周五 14:25写道：
> >
> > > Congrats, Weihua!
> > > Best,
> >
Congratulations, Matthias!
Best,
Jark
On Fri, 4 Aug 2023 at 14:59, Weihua Hu wrote:
> Congratulations, Matthias!
>
> Best,
> Weihua
>
>
> On Fri, Aug 4, 2023 at 2:49 PM Yuxin Tan wrote:
>
> > Congratulations, Matthias!
> >
> > Best,
> > Yuxin
> >
> >
> > Sergey Nuyanzin 于2023年8月4日周五 14:21写道：
Congratulations, Hong!
Best,
Jark
On Fri, 4 Aug 2023 at 14:24, Sergey Nuyanzin wrote:
> Congratulations, Hong!
>
> On Fri, Aug 4, 2023 at 7:25 AM Shammon FY wrote:
>
> > Congratulations, Hong!
> >
> > Best,
> > Shammon FY
> >
> > On Fri, Aug 4, 2023 at 12:33 PM Jing Ge
> > wrote:
> >
> > > co
Hi,
I agree with Becket that we may need to extend FieldReferenceExpression to
support nested field access (or maybe a new
NestedFieldReferenceExpression).
But I have some concerns about evolving the
SupportsProjectionPushDown.applyProjection.
A projection is much simpler than Filter Expression wh
Hi Timo,
Thanks for your proposal. I think this is a nice feature for users and I
prefer option 3.
I only have one concern about the concept of pseudo-column or
system-column,
because this is the first time we introduce it in Flink SQL. The
confusion is similar to the
question of Benchao and Serg
Hi Yunfeng,
I think this is a great idea to improve the serialization performance,
especially for batch jobs.
I'm not sure whether you have considered or tested this optimization for
batch jobs.
IMO, this optimization can be enabled by default for batch jobs, because
they don't have watermarks
and
> mark some many classes as @Internal? What is the exactly different
> > > > between
> > > > > a public class with no annotation and with the @Internal?
> > > > >
> > > > > Best regards,
> > > > > Jing
> > > > >
> >
+1 (binding)
Thanks Xintong for driving this. Thanks all for finalizing the
SourceFunction conclusion.
Best,
Jark
On Wed, 26 Jul 2023 at 22:28, Alexander Fedulov
wrote:
> +1 (non-binding), assuming SourceFunction gets added back to the
> doc as a "nice-to-have". I am glad we've reached a conse
Hi Jane,
Thanks for kicking off this work and collecting the detailed list.
+1 to add the missing annotation.
This often confuses me whether the class can be modified without breaking
the compatibility
when looking at classes in table-common and table-api. Explicitly mark the
visibility can be
1 - 100 of 1110 matches
Mail list logo
