Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Best, Jing Zhang Rui Fan <1996fan...@gmail.com> 于2023年3月28日周二 22:25写道： > Congratulations! > > Best, > Rui Fan > > On Tue, Mar 28, 2023 at 15:37 Guowei Ma wrote: > > > Congratulations! > > > > Best, > > Guowei > > &g

Re: [VOTE] Release 1.15.0, release candidate #1

Hi, Yun Gao There is a new bug [1] introduced in release-1.15. It's better to be fixed in 1.15.0 version. I'm terribly sorry to merge the pull request too late. [1] https://issues.apache.org/jira/browse/FLINK-26681 Best, Jing Zhang Johannes Moser 于2022年4月12日周二 14:53写道： > Here i

Re: [VOTE] FLIP-214: Support Advanced Function DDL

Ron, +1 (binding) Thanks for driving this FLIP. Best, Jing Zhang Jark Wu 于2022年4月21日周四 11:31写道： > Thanks for driving this work @Ron, > > +1 (binding) > > Best, > Jark > > On Thu, 21 Apr 2022 at 10:42, Man

Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features

s and uncontrolled results, often causing some unexpected problems. Thank @Godfrey for driving this discussion in a big scope. I think it's a good chance to review these problems and find a solution. Best, Jing Zhang godfrey he 于2022年4月22日周五 21:40写道： > Hi Chesnay, > > There is

Re: Re: [VOTE] FLIP-216: Introduce pluggable dialect and plan for migrating Hive dialect

+1 (binding) Best, Jing Zhang Martijn Visser 于2022年4月28日周四 20:11写道： > +1 (Binding) > > On Thu, 28 Apr 2022 at 13:40, ron wrote: > > > +1 > > > > Best, > > Ron > > > > > > > -原始邮件- > > > 发件人: "Jark Wu" > &g

Re: [VOTE] FLIP-226: Introduce Schema Evolution on Table Store

+1 Thanks @ Jingsong for driving this topic. Best, Jing Zhang Jingsong Li 于2022年5月12日周四 17:06写道： > Hi, everyone > > Thanks all for your attention to FLIP-226: Introduce Schema Evolution on > Table Store [1] and participation in the discussion in the mail thread [2]. > > I

Re: [VOTE] FLIP-231: Introduce SupportStatisticReport to support reporting statistics from source connectors

+1 (binding) Best, Jing Zhang Martijn Visser 于2022年6月9日周四 14:58写道： > +1 (binding) > > Op do 9 jun. 2022 om 04:31 schreef Jingsong Li : > > > +1 (binding) > > > > Best, > > Jingsong > > > > On Tue, Jun 7, 2022 at 5:20 PM Jark Wu wrote: >

Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee

Congratulations, Jingsong! Best, Jing Zhang Leonard Xu 于2022年6月14日周二 10:54写道： > Congratulations, Jingsong! > > > Best, > Leonard > > > 2022年6月13日 下午6:52，刘首维 写道： > > > > Congratulations and well deserved, Jingsong! > > > > > >

Re: [VOTE] FLIP-168: Speculative Execution for Batch Job

+1 (binding) Best, Jing Zhang Yun Gao 于2022年6月20日周一 14:25写道： > +1 (binding) > > Thanks for driving the FLIP! > > Best, > Yun Gao > > > -- > From:Guowei Ma > Send Time:2022 May 27 (Fri.) 11:16 &g

Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features

on these 3 points. About keeping up with the Calcite updates, I would like to take this issue. Is it too late to schedule the 1.16 version? How about scheduling this work on version 1.17? Best, Jing Zhang Martijn Visser 于2022年6月23日周四 02:01写道： > Hi everyone, > > I've recently r

[DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job

execution of sources as one of follow up of FLIP-168. You could find more details in FLIP-245[2]. Looking forward to your feedback. Best, Jing Zhang [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-168%3A+Speculative+Execution+for+Batch+Job#FLIP168:SpeculativeExecutionforBatchJob

Re: [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job

support for SourceEvent because it's useful for some user-defined sources which have a custom event protocol between reader and enumerator. Best, Jing Zhang [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-245%3A+Source+Supports+Speculative+Execution+For+Batch+Job Guowei Ma 于2022年6月29

Re: [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job

een reader and enumerator. 3. How to handle ReportedWatermarkEvent/ReaderRegistrationEvent messages. Please review the FLIP-245[1] again, looking forward to your feedback. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-245%3A+Source+Supports+Speculative+Execution+For+Batch+Job Jing Zha

Re: [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job

nment. Watermark alignment is a new feature, and still evolving. Moreover, most users will not use this feature in batch cases. So I agree not to support it in speculative execution. Best, Jing Zhang Becket Qin 于2022年7月5日周二 08:38写道： > Yes, that sounds reasonable to me. That said, supporting custo

Re: [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job

Hi everyone, Thanks a lot for all the feedback! I will open a vote for it since there is no more concern. Best, Jing Zhang Jing Zhang 于2022年7月5日周二 11:31写道： > Hi ZhuZhu, Jiangjie, > > Thanks a lot for your feedback. > > I agree that it's better to support most existing even

[VOTE] FLIP-245: Source Supports Speculative Execution For Batch Job

Hi all, I'd like to start a vote for FLIP-245: Source Supports Speculative Execution For Batch Job[1] on the discussion thread [2]. The vote will last for at least 72 hours unless there is an objection or insufficient votes. Best, Jing Zhang [1] https://cwiki.apache.org/confluence/di

Re: Re: Re: [VOTE] FLIP-218: Support SELECT clause in CREATE TABLE(CTAS)

+1 (binding) Best, Jing Zhang Mang Zhang 于2022年7月7日周四 14:39写道： > Hi Godfrey, > Thank you very much for this vote! > > > Since the titles of the two vote emails are the same, making it easy to > confuse the emails, I will count the response results of these two emails > whe

Re: [VOTE] FLIP-245: Source Supports Speculative Execution For Batch Job

+1 (binding) Best, Jing Zhang Zhu Zhu 于2022年7月6日周三 10:45写道： > +1 (binding) > > Thanks, > Zhu > > Guowei Ma 于2022年7月5日周二 17:38写道： > > > > +1 (binding) > > Best, > > Guowei > > > > > > On Tue, Jul 5, 2022 at 12:38 PM Jiangang Liu >

[RESULT][VOTE] FLIP-245: Source Supports Speculative Execution For Batch Job

Hi everyone, I’m happy to announce that FLIP-245[1] has been accepted, with 5 approving votes, 3 of which are binding[2]: - Mang Zhang - Jiangang Liu - Guowei Ma (binding) - Zhu Zhu (binding) - Jing Zhang (binding) There is no disapproving vote. [1] https://cwiki.apache.org/confluence/display

Re: [VOTE] Creating benchmark channel in Apache Flink slack

+ 1 (binding), Thanks for driving this. Best, Jing Zhang Yun Tang 于2022年7月12日周二 11:19写道： > + 1 (binding, I think this voting acts as voting a FLIP). > > > > Best, > Yun Tang > > From: Alexander Fedulov > Sent: Tuesday, July 12, 202

Re: [DISCUSS] FLIP-249: Flink Web UI Enhancement for Speculative Execution

tasks of all vertex one by one? Best, Jing Zhang Gen Luo 于2022年7月11日周一 22:31写道： > Hi, everyone. > > Thanks for your feedback. > If there are no more concerns or comments, I will start the vote tomorrow. > > Gen Luo 于 2022年7月11日周一 11:12写道： > > > Hi Lijie and Zhu, >

Re: [VOTE] FLIP-249: Flink Web UI Enhancement for Speculative Execution

Hi, Gen Luo, I left two minor questions in the DISCUSS thread. Sorry for jumping into the discussion so late. Best, Jing Zhang Lijie Wang 于2022年7月12日周二 19:29写道： > +1 (non-binding) > > Best, > Lijie > > Zhu Zhu 于2022年7月12日周二 17:38写道： > > > +1 (binding) > > &g

Re: [DISCUSS] FLIP-249: Flink Web UI Enhancement for Speculative Execution

easier way to know whether the job contains speculative executions even after the job finished. Maybe the point could be took into consideration in the next version. Best, Jing Zhang Gen Luo 于2022年7月13日周三 14:47写道： > Hi Jing, > > Thanks for joining the discussion. It's a very g

Re: [VOTE] FLIP-249: Flink Web UI Enhancement for Speculative Execution

+1 (binding) Best, Jing Zhang Gen Luo 于2022年7月13日周三 14:49写道： > Hi Jing, > > I have replied in the discussion thread about the questions. Hope that > would be helpful. > > Best, > Gen > > On Tue, Jul 12, 2022 at 8:43 PM Jing Zhang wrote: > > > Hi, Gen Luo,

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

his point into consideration. Best, Jing Zhang [1] FLIP-248: https://cwiki.apache.org/confluence/display/FLINK/FLIP-248%3A+Introduce+dynamic+partition+pruning [2] FLIP-245: https://cwiki.apache.org/confluence/display/FLINK/FLIP-245%3A+Source+Supports+Speculative+Execution+For+Batch+Job Jark Wu 于2022年

Re: [DISCUSS] FLIP-248: Introduce dynamic partition pruning

Hi, Godfrey Thanks for updating the FLIP. It looks good to me now. Best, Jing Zhang godfrey he 于2022年7月26日周二 12:33写道： > Thanks for all the inputs, I have updated the document and POC code. > > > Best, > Godfrey > > Yun Gao 于2022年7月26日周二 11:11写道： > > > > H

Re: [VOTE] FLIP-248: Introduce dynamic partition pruning

+1 (binding) Best, Jing Zhang Jingsong Li 于2022年7月27日周三 16:52写道： > +1 > > On Wed, Jul 27, 2022 at 3:30 PM Jark Wu wrote: > > > > +1 (binding) > > > > Best, > > Jark > > > > On Wed, 27 Jul 2022 at 13:34, Yun Gao > wrote: > >

Re: [DISCUSS] FLIP-435: Introduce a New Dynamic Table for Simplifying Data Pipelines

o be similar with materialized view. Will we do something like materialized view rewriting during the optimization? Best, Jing Zhang Timo Walther 于2024年3月13日周三 01:24写道： > Hi Lincoln & Ron, > > thanks for proposing this FLIP. I think a design similar to what you > propose has

Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job

n for specified operators. However the requirement is not supported currently. I think there should be some place to describe how to support it. Best, Jing Zhang Lijie Wang 于2022年12月27日周二 18:51写道： > Hi Biao, > > Thanks for driving this FLIP. > In this FLIP, it introduces "int

Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job

Hi Biao, Thanks for explanation. +1 for the proposal. Best, Jing Zhang Lijie Wang 于2023年1月4日周三 12:11写道： > Hi Biao, > > Thanks for the explanation of how SinkV2 knows the right subtask > attempt. I have no more questions, +1 for the proposal. > > Best, > Lijie > >

Re: [VOTE] FLIP-281: Sink Supports Speculative Execution For Batch Job

+1 (binding) Best, Jing Zhang Lijie Wang 于2023年1月12日周四 16:39写道： > +1 (binding) > > Best, > Lijie > > Martijn Visser 于2023年1月12日周四 15:56写道： > > > +0 (binding) > > > > Op di 10 jan. 2023 om 13:11 schreef yuxia : > > > > > +

Re: [VOTE] Release 1.16.1, release candidate #1

Client, query result is expected - run some batch jobs, query results are almost as expected except the issue FLINK-30567[1]. It’s not a blocker issue, so it would be OK to cherry pick the bugfix to 1.16.2 version later as well. [1] https://issues.apache.org/jira/browse/FLINK-30567 Best, Jing Zhang

Re: [DISCUSS] SQL CTAS Syntax

en/create-table-select.html, the result is a bit unexpected, I wonder What the behavior would be in Flink. [image: image.png] Best, JING ZHANG

Re: [Discuss] Planning Flink 1.14

wing+table-valued+function#FLIP145:SupportSQLwindowingtablevaluedfunction-CumulatingWindows Best regards, JING ZHANG Xintong Song 于2021年6月2日周三 下午6:45写道： > Hi all, > > As 1.13 has been released for a while, I think it is a good time to start > planning for the 1.14 release cycle. > &

Re: [Discuss] Planning Flink 1.14

ot support state compatibility yet. Best regards, JING ZHANG Prasanna kumar 于2021年6月4日周五 下午2:27写道： > Hi all, > > We are using Flink for our eventing system. Overall we are very happy with > the tech, documentation and community support and quick replies in mails. > > My last 1 y

Re: Add control mode for flink

careful design. [ http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dynamic-configuration-of-Flink-checkpoint-interval-td44059.html ] Best regards, JING ZHANG 刘建刚 于2021年6月8日周二 上午10:01写道： > Thanks Xintong Song for the detailed supplement. Since flink is > long-running,

Re: Flink TM Heartbeat Timeout

Hi Lu, Xintong has a professional analysis about TM heartbeat timeout in a historical mail[1], please check if it could help. [1] http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Heartbeat-of-TaskManager-timed-out-td36228.html Best regards, JING ZHANG Lu Niu 于2021年6月11日周五 上午

Re: [DISCUSS] FLIP-129 (Update): Registering sources/sinks on Table API without SQL

Thanks Ingo for starting this discussion. Big +1 for this feature. Looking forward to the feature. Best regards, JING ZHANG Jark Wu 于2021年6月15日周二 下午3:48写道： > Thanks Ingo for picking up this FLIP. > > FLIP-129 is an important piece to have a complete Table SQL story, > and use

Re: [ANNOUNCE] New PMC member: Xintong Song

Congratulations, Xintong! Jiayi Liao 于2021年6月16日周三 下午7:30写道： > > > > > > Congratulations Xintong! > > > > On Wed, Jun 16, 2021 at 7:24 PM Nicholas Jiang > > wrote: > > > >> Congratulations, Xintong! > >> > >> > >> > >> -- > >> S

Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations, Arvid! Nicholas Jiang 于2021年6月16日周三 下午7:25写道： > Congratulations, Arvid! > > > > -- > Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ >

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

+1 (binding) Best regards, JING ZHANG Jingsong Li 于2021年6月22日周二 上午10:11写道： > +1 (binding) > > Thanks for driving. > > Best, > Jingsong > > On Tue, Jun 22, 2021 at 12:07 AM Jark Wu wrote: > > > +1 (binding) > > > > Best, > > Jark > &

Re: [DISCUSS] Feedback Collection Jira Bot

hesnay about not un-assign an issue if a PR is open. Besides, Could assignees remove the "stale-assigned" tag by themself? It seems assignees have no permission to delete the tag if the issue is not created by themselves. Best regards, JING ZHANG Konstantin Knauf 于2021年6月23日周三 下午4:17

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

uture. Best regards, JING ZHANG Stephan Ewen 于2021年6月23日周三 下午8:16写道： > +1 to Xintong's proposal > > On Wed, Jun 23, 2021 at 1:53 PM Till Rohrmann > wrote: > > > I would first try to not introduce the exception for local builds. It > makes > > it quite hard for oth

Re: [VOTE] FLIP-169: DataStream API for Fine-Grained Resource Requirements

+1 (binding) Thanks Yangze for driving the issue. Best regards, JING ZHANG Yang Wang 于2021年6月24日周四 下午1:51写道： > +1 (non-binding) > > Best, > Yang > > 刘建刚 于2021年6月24日周四 下午12:17写道： > > > +1 (binding) > > > > Thanks > > liujiangang > >

Re: [Question] Why doesn't Flink use Calcite adapter?

correct me if I'm wrong. Best regards, JING ZHANG [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sourcessinks/ Israel Ekpo 于2021年6月28日周一 上午8:28写道： > Maybe this question was better addressed to the DEV list. > > On Fri, Jun 25, 2021 at 11:57 PM

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

gt; > > > > > > > > > > > > > > > On Thu, 24 Jun 2021 at 10:04, Xintong Song < > > > > tonysong...@gmail.com> > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > Thanks all for the feedback. > &g

[DISCUSS] Better user experience in the WindowAggregate upon Changelog (contains update message)

-fire.delay` to 0s. And in the later version, we deprecate `table.exec.emit.late-fire.delay` and `table.exec.emit.allow-lateness `. Please let me know what you think about the issue. Thank you. [1] https://issues.apache.org/jira/browse/FLINK-22781 Best regards, JING ZHANG

Re: [VOTE] FLIP-147: Support Checkpoint After Tasks Finished

+1 (binding) Arvid Heise 于2021年7月1日周四 下午3:10写道： > Looks good: +1 (binding) > > On Tue, Jun 29, 2021 at 5:06 AM 刘建刚 wrote: > > > +1 (binding) > > > > Best > > liujiangang > > > > Piotr Nowojski 于2021年6月29日周二 上午2:05写道： > > > > > +1 (binding) > > > > > > Piotrek > > > > > > pon., 28 cze 2021 o 1

Re: [VOTE] Release 1.13.2, release candidate #1

Hi yun, Website pull request lists[6] and JIRA release notes[1] both contain unfinished JIRA (such as FLINK-22955). Is it expected? Best regards, JING ZHANG Dawid Wysakowicz 于2021年7月2日周五 下午9:05写道： > +1 (binding) > >- verified signatures and checksums >- reviewed the ann

Re: [VOTE] Release 1.13.2, release candidate #1

/log 4. Started cluster and run some e2e sql queries using SQL Client, query result is expected. 5. Repeat Step 3 and 4 with flink-1.13.2-bin-scala_2.11.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.13.2-rc1/flink-1.13.2-bin-scala_2.11.tgz> Best regards, JING ZHANG Zakelly Lan 于20

Re: [ANNOUNCE] New Apache Flink Committer - Yang Wang

Congratulations! Yang Wang! Best regards, JING ZHANG Zakelly Lan 于2021年7月7日周三 上午10:31写道： > Congrats & well deserved, Yang Wang! > > Best, > Zakelly > > On Wed, Jul 7, 2021 at 10:30 AM 刘建刚 wrote: > > > Congratulations, Yang Wang. > > > > Best > &

Re: [ANNOUNCE] New PMC member: Guowei Ma

Congratulations, Guowei Ma! Best regards, JING ZHANG Zakelly Lan 于2021年7月7日周三 上午10:30写道： > Congratulations, Guowei! > > Best, > Zakelly > > On Wed, Jul 7, 2021 at 10:24 AM tison wrote: > > > Congrats! NB. > > > > Best, > > tison

Re: [VOTE] Release 1.13.2, release candidate #1

run some e2e sql queries using SQL Client, query result is expected. 5. Repeat Step 3 and 4 with flink-1.13.2-bin-scala_2.11.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.13.2-rc1/flink-1.13.2-bin-scala_2.11.tgz> Best regards, JING ZHANG Xintong Song 于2021年7月7日周三 上午11:09写道： > H

Re: [VOTE] Release 1.12.5, release candidate #1

n some e2e sql queries using SQL Client, query result is expected. 4. Repeat Step 2 and 3 with flink-1.12.5-bin-scala_2.11.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.12.5-rc1/flink-1.12.5-bin-scala_2.11.tgz> Best, JING ZHANG Yang Wang 于2021年7月7日周三 上午11:36写道： >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yuan Mei

Congratulations, Yuan! Rui Li 于2021年7月8日周四 上午10:52写道： > Congratulations Yuan! > > On Thu, Jul 8, 2021 at 10:51 AM Yun Gao > wrote: > > > Congratulations Yuan! > > > > Best, > > Yun > > > > > > > > --Original Mail -- > > Sender:Zhilong Hong > > Send Date:Thu Jul

Re: Still receiving these emails.. please unsubscribe me

...@flink.apache.org For more information, please go to [1]. [1] https://flink.apache.org/community.html Best, JING ZHANG R Bhaaagi 于2021年7月23日周五 下午5:45写道： > Hi Team, > > Please unsubscribe me from all these emails > > On Fri, 23 Jul 2021 at 2:19 PM, LINZ, Arnaud >

Re: [VOTE] Release 1.11.4, release candidate #1

Thanks @godfrey for driving this. +1 (non-binding) 1. built from source code flink-1.11.4-src.tgz succeeded 2. Started a local Flink cluster, ran the WordCount example, WebUI looks good, no suspicious output/lo

Re: [VOTE] Release 1.12.5, release candidate #3

c.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.12.5-rc3/flink-1.12.5-src.tgz> Best, JING ZHANG Dian Fu 于2021年8月2日周一 上午9:59写道： > +1 (binding) > > - checked the website PR > - verified the signatures and checksum > - Installed the Python wheel package of Python 3.8 on MacO

Re: Were Bundles meant to be internal?

assed in you case. Best, JING ZHANG David Anderson 于2021年8月19日周四 下午10:15写道： > Most of the table/bundle related classes such as > MapBundleFunction, MapBundleOperator, and CountBundleTrigger aren't marked > as either @Internal or @Public. What was the intention? > > I ask be

Re: How heap state backend serialization happens during snapshotting

, JING ZHANG Muhammad Haseeb Asif 于2021年8月27日周五 上午2:41写道： > Hello, > > I have been trying to understand how serialization works for the Flink > Heap Keyed state backend when a checkpoint happens. I want to know how > Flink knows which type of serializer to use to serialize the values

Re: One idea for Graceful Application Evolvement

operator has changed, whether need to fulfill the data, whether need to recover state, and how? Best, JING ZHANG Kurt Young 于2021年9月3日周五 上午9:15写道： > Could you explain why you need a backfill after you take v2 into > production? > > Best, > Kurt > > > On Fri, Sep 3, 2021 at 2:

Re: [ANNOUNCE] Flink mailing lists archive service has migrated to Apache Archive service

Thanks Leonard for driving this. The information is helpful. Best, JING ZHANG Jark Wu 于2021年9月6日周一 下午4:59写道： > Thanks Leonard, > > I have seen many users complaining that the Flink mailing list doesn't > work (they were using Nabble). > I think this information would be ve

Re: [DISCUSS] Automated architectural tests

` could be covered by all `MetadataHandler`s. Currently this rule not exists yet. Best regards, JING ZHANG Ingo Bürk 于2021年9月9日周四 下午6:49写道： > Great! I'll work on getting the PR into an actual, proper shape now, > including looking at found violations more carefully and eventually > fr

Re: 退订

...@flink.apache.org For more information, please go to [1]. [1] https://flink.apache.org/community.html#mailing-lists Best, JING ZHANG maozhaolin 于2021年9月26日周日 下午3:28写道： > 退订

Re: [VOTE] Release 1.14.0, release candidate #3

pache.org/repos/dist/dev/flink/flink-1.14.0-rc3/flink-1.14.0-bin-scala_2.12.tgz> - test window TVF related sql, query result is expected Best, JING ZHANG Zhu Zhu 于2021年9月26日周日 下午6:38写道： > +1 (binding) > - checked signatures and checksums > - built from source > - ran large s

Re: [ANNOUNCE] Apache Flink 1.14.0 released

Great! Thanks David, Joe, Xintong and everyone who makes this possible. Best, JING ZHANG Leonard Xu 于2021年10月1日周五 上午10:20写道： > Congratulations! > > Thanks Dawid, Xintong and Joe for being our release managers and everyone > who contributed to this release. > > Best, > Leon

Re: [NOTICE] CiBot improvements

mes I'm not sure the passed cases in the last build could still success in the new build because of introduced updates in new commit. Best, JING ZHANG Yangze Guo 于2021年10月11日周一 上午10:31写道： > Thanks for that great job, Chesnay! "Rerun failed jobs" will help a lot. > > Best, &

Re: [VOTE] Release 1.13.3, release candidate #1

flink-1.13.3-bin-scala_2.12.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.13.3-rc1/flink-1.13.3-bin-scala_2.12.tgz> Best, JING ZHANG Matthias Pohl 于2021年10月15日周五 下午10:07写道： > Thanks Chesnay for driving this. > > +1 (non-binding) > > - verified the checksums

Re: Multiple View Creation support

Hi, I'm not sure I understand your question. Are you looking for a way to define multiple view in SQL? Please try define multiple view by define multiple create view query, you could find create view syntax in document [1] Please let me know if I misunderstand your requirement. [1] https://nightli

Re: [ANNOUNCE] Apache Flink 1.13.3 released

Thank Chesnay, Martijn and every contributor for making this happen! Thomas Weise 于2021年10月22日周五 上午12:15写道： > Thanks for making the release happen! > > On Thu, Oct 21, 2021 at 5:54 AM Leonard Xu wrote: > > > > Thanks to Chesnay & Martijn and everyone who made this release happen. > > > > > > >

Re: Re: [NOTICE] CiBot improvements

'run azure' for two times, nothing happened which is different from the behavior in the past. I ask some other guys, they said they also meet with this problem. Please help me check whether it is expected, thanks a lot. [image: image.png] Best, JING ZHANG Yuepeng Pan 于2021年10月12日周二 下午8:

Re: [NOTICE] CiBot improvements

; It's working just fine. You need to rebase your branch because on your > > branch flink-python is simply broken. > > > > On 29/10/2021 08:57, JING ZHANG wrote: > >> Hi Chesnay, > >> I meet with something weird. > >> I submit a pull req

Re: [DISCUSS] FLIP-189: SQL Client Usability Improvements

Amazing improvements and impressive video. Big +1. Best, JING ZHANG Kurt Young 于2021年11月2日周二 上午9:37写道： > Really cool improvements @Sergey. Can't wait to see it happen. > > Best, > Kurt > > > On Tue, Nov 2, 2021 at 1:56 AM Martijn Visser > wrote: > > >

Re: I want to contribute to Apache Flink

] https://flink.apache.org/contributing/how-to-contribute.html Best, JING ZHANG shiyuquan 于2021年11月5日周五 下午7:22写道： > Hi Guys, > > > I want to contribute to Apache Flink. > Would you please give me the permission as a contributor? My JIRA ID is > shiyuquan. > > > Thanks! > >

Re: [VOTE] FLIP-189: SQL Client Usability Improvements

+1 (non-binding) Best, JING ZHANG Leonard Xu 于2021年11月9日周二 上午10:56写道： > +1 (non-binding) > > Thanks for the Improvements. > > Best, > Leonard > > 在 2021年11月9日，10:08，Yuepeng Pan 写道： > > > > +1 (non-binding)Best, > > Roc > > > > At 2

Re: [DISCUSS] Improve the name and structure of job vertex and operator name for job

Big +1. This is a problem frequently encountered in our production platform, look forward to this improvement. Best, Jing Zhang Martijn Visser 于2021年11月11日周四 下午6:26写道： > +1. Looks much better now > > On Thu, 11 Nov 2021 at 11:07, godfrey he wrote: > > > Thanks for

Re: [VOTE] FLIP-188 Introduce Built-in Dynamic Table Storage

queues*, data copying may be avoided. So the built-in dynamic table storage may be promoted faster in the streaming data warehouse business. Best regards, Jing Zhang Yufei Zhang 于2021年11月11日周四 上午9:34写道： > Hi, > > +1 (non-binding) > > Very interesting design. I saw a lot of discussion

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

Congrat! Best, Jing Zhang Lijie Wang 于2021年11月12日周五 下午1:26写道： > Congrats Leonard! > > Best, > Lijie > > Yuan Mei 于2021年11月12日周五 下午1:11写道： > > > Congrats Leonard! > > > > Best > > Yuan > > > > > > On Fri, Nov 12, 2021

Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo

Congrats! Best, Jing Zhang Lijie Wang 于2021年11月12日周五 下午1:25写道： > Congrats Yangze! > > Best, > Lijie > > Yuan Mei 于2021年11月12日周五 下午1:10写道： > > > Congrats Yangze! > > > > Best > > Yuan > > > > On Fri, Nov 12, 2021 at 11:57 AM Leon

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! Best, Jing Zhang Yuepeng Pan 于2021年11月16日周二 上午10:16写道： > Congratulations Fabian! > > Best, > Yuepeng Pan > > At 2021-11-15 21:17:13, "Arvid Heise" wrote: > >Hi everyone, > > > >On behalf of the PMC, I'm very happy to

Re: [ANNOUNCE] New Apache Flink Committer - Jing Zhang

Thanks to everyone. It's my honor to work in community with you all. Best, Jing Zhang Zakelly Lan 于2021年11月17日周三 上午12:06写道： > Congratulations, Jing! > > Best, > Zakelly > > On Tue, Nov 16, 2021 at 11:03 PM Yang Wang wrote: > >> Congratulations, Jing! >>

Re: [ANNOUNCE] New Apache Flink Committer - Yingjie Cao

Congratulations! Best, Jing Zhang Dian Fu 于2021年11月17日周三 下午8:07写道： > Congratulations! > > Regards, > Dian > > On Wed, Nov 17, 2021 at 5:14 PM Yang Wang wrote: > > > Congratulations, Yiingjie! > > > > Best, > > Yang > > > > Zakell

Re: [VOTE][FLIP-195] Improve the name and structure of vertex and operator name for job

+1 (non-binding) Best, Jing Zhang Martijn Visser 于2021年11月23日周二 下午7:42写道： > +1 (non-binding) > > On Tue, 23 Nov 2021 at 12:13, Aitozi wrote: > > > +1 (non-binding) > > > > Best, > > Aitozi > > > > wenlong.lwl 于2021年11月23日周二 下午4:00写道： > >

Re: [ANNOUNCE] Open source of remote shuffle project for Flink batch data processing

Amazing! Remote shuffle service is an important improvement for batch data processing experience on Flink. It is also a strong requirement in our internal batch business, we would try it soon and give you feedback. Best, Jing Zhang Martijn Visser 于2021年12月1日周三 上午3:25写道： > Hi Yingjie, >

Re: [ANNOUNCE] New Apache Flink Committer - Matthias Pohl

Congratulations, Matthias! 刘建刚 于2021年12月3日周五 11:51写道： > Congratulations！ > > Best, > Liu Jiangang > > Till Rohrmann 于2021年12月2日周四 下午11:28写道： > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Matthias Pohl as a new > > Flink committer. > > > > Matthias has worked on Fli

Re: [ANNOUNCE] New Apache Flink Committer - Ingo Bürk

Congratulations, Ingo! 刘建刚 于2021年12月3日周五 11:52写道： > Congratulations！ > > Best, > Liu Jiangang > > Till Rohrmann 于2021年12月2日周四 下午11:24写道： > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Ingo Bürk as a new Flink > > committer. > > > > Ingo has started contributing to F

Re: [DISCUSS] FLIP-190: Support Version Upgrades for Table API & SQL Programs

to the latest version. This might also appears in other company too. Could we guarantee FLIP-190 work if we skip minor versions less than specified threshold? Then we could know which version is good for us when prepare upgrading. Best, Jing Zhang godfrey he 于2021年12月8日周三 22:16写道： > Hi Timo

Re: [DISCUSS] FLIP-190: Support Version Upgrades for Table API & SQL Programs

Hi Timo, +1 for the improvement too. Please count me in when assign subtasks. Best, Jing Zhang Timo Walther 于2021年12月13日周一 17:00写道： > Hi everyone, > > *last call for feedback* on this FLIP. Otherwise I would start a VOTE by > tomorrow. > > @Wenlong: Thanks for offering y

Re: [DISCUSS] Immediate dedicated Flink releases for log4j vulnerability

+1 for the quick release. Till Rohrmann 于2021年12月13日周一 17:54写道： > +1 > > Cheers, > Till > > On Mon, Dec 13, 2021 at 10:42 AM Jing Ge wrote: > > > +1 > > > > As I suggested to publish the blog post last week asap, users have been > > keen to have such urgent releases. Many thanks for it. > > > >

Re: [VOTE] FLIP-190: Support Version Upgrades for Table API & SQL Programs

+1 Thanks for driving this, Timo. Best, Jing Zhang wenlong.lwl 于2021年12月15日周三 13:31写道： > +1 (non-binding). Thanks for driving this Timo > > > Best, > Wenlong > > On Wed, 15 Dec 2021 at 03:21, Martijn Visser > wrote: > > > +1 (non-binding). Thanks for drivi

[DISCUSS] Introduce Hash Lookup Join

ay, the difference between the two solution is only about the internal implementation and has no impact on the user. For more detail on the proposal: https://cwiki.apache.org/confluence/display/FLINK/FLIP-204%3A+Introduce+Hash+Lookup+Join Looking forward to your feedback, thanks. Best, Jing Zhang

Re: [DISCUSS] Introduce Hash Lookup Join

https://calcite.apache.org/docs/reference.html#sql-hints Best, Jing Zhang Martijn Visser 于2021年12月28日周二 22:02写道： > Hi Jing, > > Thanks a lot for the explanation and the FLIP. I definitely learned > something when reading more about `use_hash`. My interpretation would be > that the

Re: [DISCUSS] Introduce Hash Lookup Join

I would not do this point in this FLIP right now. If this is a strong requirement, we need drive another discussion on this topic individually because this point involves many extension on API. Best, Jing Zhang Lincoln Lee 于2021年12月29日周三 10:01写道： > Hi Jing, > Thanks for bringing up

Re: [DISCUSS] Introduce Hash Lookup Join

m very happy to hear that you point out there're more limitations except for `Correlate`, would you please give more details on this part? Best, Jing Zhang [1] https://docs.databricks.com/delta/join-performance/skew-join.html [2] https://help.aliyun.com/apsara/enterprise/v_3_13_0_20201215/odps/e

Re: Re: [DISCUSS] Introduce Hash Lookup Join

s 'SHUFFLE_HASH' [2]. SQL Server uses keyword 'HASH' instead of query hint [3]. Note, the purposes of hash shuffle in [1][2][3] are a little different from the purpose of FLIP-204, we just discuss syntax here. I've added this part to FLIP waiting for further

Re: Re: [DISCUSS] Introduce Hash Lookup Join

h shuffle. WDYT? Best, Jing Zhang [1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/#connector-options [2] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/hbase/#connector-options Jing Zhang 于2021年12月29日周三 20:37写道： > Hi Wenlong,

Re: Re: [DISCUSS] Introduce Hash Lookup Join

input, there exists a little difference between them. About this point, Lincoln and WenLong both prefer the term 'SHUFFLE_HASH', WDYT? Best, Jing Zhang Lincoln Lee 于2021年12月30日周四 11:21写道： > Hi Jing, > Thanks for your explanation! > > 1. For the hint name, +1 for WenLong&#

Re: Re: [DISCUSS] Introduce Hash Lookup Join

hint has different function. The'USE_HASH' hint suggests the optimizer use hash partitioner for Lookup Join for table 'Orders' and table 'Customers' while the 'SKEW' hint tells the optimizer the skew metadata about the table 'Orders'. Best, Jing Zha

Re: Re: [DISCUSS] Introduce Hash Lookup Join

or table would not be lost in the sql conversion phase and sql optimization phase. So here we only support table names. Best, Jing Zhang Francesco Guardiani 于2022年1月3日周一 18:38写道： > Hi Jing, > > Thanks for the FLIP. I'm not very knowledgeable about the topic, but going > throu

Re: Re: [DISCUSS] Introduce Hash Lookup Join

Hi all, Thanks for all the feedback so far. If there is no more suggestions, I would like to drive a vote in Tuesday next week (18 Jan). Best, Jing Zhang Jing Zhang 于2022年1月5日周三 11:33写道： > Hi Francesco, > Thanks a lot for the feedback. > > > does it makes sense for a lookup j

  1   2   >