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

+1 (non-binding) - verified signatures and hashsums - started a cluster, ran a socket window word count job, no suspicious log output - tested using SQL Client to submit job and the query result is expected - the web PR looks good Best, Leonard > 在 2021年7月31日，09:08，godfrey he 写道： > > +1

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

Congratulations Yuan. Best, Leonard > 在 2021年7月8日，09:49，Qingsheng Ren 写道： > > Congratulations Yuan! > > -- > Best Regards, > > Qingsheng Ren > Email: renqs...@gmail.com > 2021年7月8日 +0800 09:45 Xintong Song ，写道： >> Congratulations Yuan~! >> >> Thank you~ >> >> Xintong Song >> >> >> >> On

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

+1 (non-binding) - verified signatures and hashsums - built from source code with scala 2.11 succeeded - checked all denpendency artifacts are 1.12.5 - started a cluster, ran a wordcount job, the result is expected - started SQL Client, ran a simple query, the result is expected - reviewed the

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

Congratulations! Yang Wang Best, Leonard > 在 2021年7月7日，10:23，tison 写道： > > Congratulations and well deserved! > > It is my pressure to work with you excellent developer. > > Best, > tison. > > > Jark Wu 于2021年7月7日周三 上午10:21写道： > >> Congratulations Yang Wang! >> >> Best, >> Jark >> >>

Re: [ANNOUNCE] The term "blink" has been removed from the code base

Thanks Timo for the great work. Developers and user can finally care about only one planner after Flink 1.14 released. Cheers, Leonard > 在 2021年7月6日，23:51，Timo Walther 写道： > > Hi everyone, > > as discussed previously [1] and tracked in FLINK-14437, we executed the last > step of FLIP-32

Re: [ANNOUNCE] New PMC member: Guowei Ma

Congratulations! Guowei Ma Best, Leonard > 在 2021年7月6日，21:56，Kurt Young 写道： > > Hi all! > > I'm very happy to announce that Guowei Ma has joined the Flink PMC! > > Congratulations and welcome Guowei! > > Best, > Kurt

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

+1, This may help https://issues.apache.org/jira/browse/FLINK-22764 Best, Leonard > 在 2021年7月2日，10:17，JING ZHANG 写道： > > +1 (binding) > > > Arvid Heise 于2021年7月1日周四 下午3:10写道： > >> Looks good: +1 (binding) >> >> On Tue, Jun 29, 2021 at

Re: [DISCUSS] Drop Mesos in 1.14

+ 1 for dropping Mesos. I checked both commit history and mail list, the Mesos related issue/user question has been rarely appeared. Best, Leonard

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

+1 Thanks Ingo for picking up this FLIP. Best, Leonard > 在 2021年6月22日，10:16，JING ZHANG 写道： > > +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

Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations, Arvid! > 在 2021年6月16日，20:08，Till Rohrmann 写道： > > Congratulations, Arvid! > > Cheers, > Till > > On Wed, Jun 16, 2021 at 1:47 PM JING ZHANG wrote: > >> Congratulations, Arvid! >> >> Nicholas Jiang 于2021年6月16日周三 下午7:25写道： >> >>> Congratulations, Arvid! >>> >>> >>> >>>

Re: [ANNOUNCE] New PMC member: Xintong Song

Congratulations, Xintong! Best, Leonard > 在 2021年6月16日，20:07，Till Rohrmann 写道： > > Congratulations, Xintong! > > Cheers, > Till > > On Wed, Jun 16, 2021 at 1:47 PM JING ZHANG wrote: > >> Congratulations, Xintong! >> >> >> Jiayi Liao 于2021年6月16日周三 下午7:30写道： >>

[jira] [Created] (FLINK-22942) Disable upsert into syntax in Flink SQL

Leonard Xu created FLINK-22942: -- Summary: Disable upsert into syntax in Flink SQL Key: FLINK-22942 URL: https://issues.apache.org/jira/browse/FLINK-22942 Project: Flink Issue Type: Improvement

Re: How to unsubscribe?

Hi, Morgan Just send an email with any content to user-unsubscr...@flink.apache.org will unsubscribe the mail from Flink user mail list. And also send an email to with any content to dev-unsubscr...@flink.apache.org

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

+1 (non-binding) - verified signatures and hashes - built from source code with scala 2.11 succeeded - started a cluster, WebUI was accessible, ran a window word count job, no suspicious log output - ran some SQL jobs in SQL Client, the queries result is expected - the web PR looks good Best,

[jira] [Created] (FLINK-22764) Disable Values Source node in streaming plan optimization

Leonard Xu created FLINK-22764: -- Summary: Disable Values Source node in streaming plan optimization Key: FLINK-22764 URL: https://issues.apache.org/jira/browse/FLINK-22764 Project: Flink Issue

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

+1 (non-binding) - verified signatures and hashes - started a cluster, WebUI was accessible - ran some queries in SQL Client, no suspicious log output - the web PR looks good Best, Leonard Xu > 在 2021年5月19日，18:42，Chesnay Schepler 写道： > > +1 (binding) > > - checked repo

Re: [ANNOUNCE] Apache Flink 1.13.0 released

Thanks Dawid & Guowei for the great work, thanks everyone involved. Best, Leonard > 在 2021年5月5日，17:12，Theo Diefenthal 写道： > > Thanks for managing the release. +1. I like the focus on improving operations > with this version. > > Von: "Matthias Pohl" > An: "Etienne Chauchot" > CC: "dev" ,

[jira] [Created] (FLINK-22525) The zone id in exception message should be GMT+08:00 instead of GMT+8:00

Leonard Xu created FLINK-22525: -- Summary: The zone id in exception message should be GMT+08:00 instead of GMT+8:00 Key: FLINK-22525 URL: https://issues.apache.org/jira/browse/FLINK-22525 Project: Flink

Re: [VOTE] Release 1.13.0, release candidate #2

PR looks good - found one minor exception message typo, will improve it later Best, Leonard Xu > 在 2021年4月29日，16:11，Xingbo Huang 写道： > > +1 (non-binding) > > - verified checksum and signature > - test upload `apache-flink` and `apache-flink-libraries` to test.pypi > - pip

[jira] [Created] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

Leonard Xu created FLINK-22472: -- Summary: The real partition data produced time is behind meta(_SUCCESS) file produced Key: FLINK-22472 URL: https://issues.apache.org/jira/browse/FLINK-22472 Project

[jira] [Created] (FLINK-22428) Translate timezone page to Chinese

Leonard Xu created FLINK-22428: -- Summary: Translate timezone page to Chinese Key: FLINK-22428 URL: https://issues.apache.org/jira/browse/FLINK-22428 Project: Flink Issue Type: Task

Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

Congratulations Rui Li ! Best, Leonard > 在 2021年4月22日，14:43，Benchao Li 写道： > > Congratulations Rui! > > Jingsong Li 于2021年4月22日周四 下午2:33写道： > >> Congratulations Rui! >> >> Best, >> Jingsong >> >> On Thu, Apr 22, 2021 at 11:52 AM Yun Gao >> wrote: >> >>> Congratulations Rui! >>> >>>

[jira] [Created] (FLINK-22374) ConfigOptionsDocsCompletenessITCase fails on traivs

Leonard Xu created FLINK-22374: -- Summary: ConfigOptionsDocsCompletenessITCase fails on traivs Key: FLINK-22374 URL: https://issues.apache.org/jira/browse/FLINK-22374 Project: Flink Issue Type

[jira] [Created] (FLINK-22179) Manual test time function changes and new time attributes support

Leonard Xu created FLINK-22179: -- Summary: Manual test time function changes and new time attributes support Key: FLINK-22179 URL: https://issues.apache.org/jira/browse/FLINK-22179 Project: Flink

[jira] [Created] (FLINK-22177) Add docs for consistent time functions and compatibility specification

Leonard Xu created FLINK-22177: -- Summary: Add docs for consistent time functions and compatibility specification Key: FLINK-22177 URL: https://issues.apache.org/jira/browse/FLINK-22177 Project: Flink

[jira] [Created] (FLINK-22074) testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed

Leonard Xu created FLINK-22074: -- Summary: testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed Key: FLINK-22074 URL: https

Apply external 3 days for FLINK-20387 after feature freeze

Hi, Dawid & Guowei Sorry to apply the extension, I want to apply 3 days for ticket [FLINK-20387] Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime[1], it is the last ticket of FLIP-162[2] which aims to solve various time zone issues and offer a consistent time function

[jira] [Created] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

Leonard Xu created FLINK-21984: -- Summary: Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision) Key: FLINK-21984 URL: https://issues.apache.org/jira/browse/FLINK-21984

[jira] [Created] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

Leonard Xu created FLINK-21978: -- Summary: Disable cast conversion between Numeric type and TIMESTAMP_LTZ type Key: FLINK-21978 URL: https://issues.apache.org/jira/browse/FLINK-21978 Project: Flink

[jira] [Created] (FLINK-21947) Support TIMESTAMP_LTZ type in CSV format

Leonard Xu created FLINK-21947: -- Summary: Support TIMESTAMP_LTZ type in CSV format Key: FLINK-21947 URL: https://issues.apache.org/jira/browse/FLINK-21947 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21917) Add back missing zh docs

Leonard Xu created FLINK-21917: -- Summary: Add back missing zh docs Key: FLINK-21917 URL: https://issues.apache.org/jira/browse/FLINK-21917 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-21820) JDBC connector shouldn't read all rows in per statement by default

Leonard Xu created FLINK-21820: -- Summary: JDBC connector shouldn't read all rows in per statement by default Key: FLINK-21820 URL: https://issues.apache.org/jira/browse/FLINK-21820 Project: Flink

[jira] [Created] (FLINK-21716)  Support higher precision for Data Type TIME(p)

Leonard Xu created FLINK-21716: -- Summary:  Support higher precision for Data Type TIME(p) Key: FLINK-21716 URL: https://issues.apache.org/jira/browse/FLINK-21716 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-21715) Introduce more conversion classes for LocalZonedTimestampType(TIMESTAMP_LTZ)

Leonard Xu created FLINK-21715: -- Summary: Introduce more conversion classes for LocalZonedTimestampType(TIMESTAMP_LTZ) Key: FLINK-21715 URL: https://issues.apache.org/jira/browse/FLINK-21715 Project

[jira] [Created] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME()

Leonard Xu created FLINK-21714: -- Summary: Use TIMESTAMP_LTZ as return type for function PROCTIME() Key: FLINK-21714 URL: https://issues.apache.org/jira/browse/FLINK-21714 Project: Flink Issue

[jira] [Created] (FLINK-21713) Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

Leonard Xu created FLINK-21713: -- Summary: Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP Key: FLINK-21713 URL: https://issues.apache.org/jira/browse/FLINK-21713

[jira] [Created] (FLINK-21698) Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

Leonard Xu created FLINK-21698: -- Summary: Disable problematic cast conversion between NUMERIC type and TIMESTAMP type Key: FLINK-21698 URL: https://issues.apache.org/jira/browse/FLINK-21698 Project

Re: [DISCUSS] FLIP-162 follow-up discussion

1 08:14, Kurt Young wrote: >>> Hi Leonard, >>> >>> Thanks for this careful consideration. Given the fallback option will >>> eventually change the behavior twice, which means >>> potentially break user's job twice, I would also +1 to not introduce it.

Re: [DISCUSS] Apache Flink Jira Process

Thanks Konstantin for driving this topic. Generally +1 for the proposal, I went through the doc and have two concerns here. Will the robot send all notifications to assignee/reporter/watchers ? I’m a little worried about too many push messages. Eg, I watched some issues that I want to

Re: [ANNOUNCE] Apache Flink 1.12.2 released

Well done! Thanks to Roman and Yuan, and everyone who contributed to the release. Best, Leonard > 在 2021年3月9日，11:39，Zhu Zhu 写道： > > Thanks Roman and Yuan for being the release managers! Thanks everyone who has > made this release possible! > > Cheers, > Zhu > > Piotr Nowojski

[DISCUSS] FLIP-162 follow-up discussion

Hi, all As the FLIP-162 discussed, we agreed current time functions’ behavior is incorrect and plan to introduce the option table.exec.fallback-legacy-time-function to enable user fallback to incorrect behavior. (1) The option is convenient for users who want to upgrade to 1.13 but don't

[jira] [Created] (FLINK-21624) Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions

Leonard Xu created FLINK-21624: -- Summary: Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions Key: FLINK-21624 URL: https://issues.apache.org/jira/browse/FLINK-21624 Project: Flink

[jira] [Created] (FLINK-21623) Introduce CURRENT_ROW_TIMESTAMP function

Leonard Xu created FLINK-21623: -- Summary: Introduce CURRENT_ROW_TIMESTAMP function Key: FLINK-21623 URL: https://issues.apache.org/jira/browse/FLINK-21623 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

Leonard Xu created FLINK-21622: -- Summary: Introduce function TO_TIMESTAMP_LTZ(numeric [, precision]) Key: FLINK-21622 URL: https://issues.apache.org/jira/browse/FLINK-21622 Project: Flink

[jira] [Created] (FLINK-21621) Support TIMESTAMP_LTZ arithmetic

Leonard Xu created FLINK-21621: -- Summary: Support TIMESTAMP_LTZ arithmetic Key: FLINK-21621 URL: https://issues.apache.org/jira/browse/FLINK-21621 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21620) [table-planner/table-parser] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

Leonard Xu created FLINK-21620: -- Summary: [table-planner/table-parser] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE Key: FLINK-21620 URL: https://issues.apache.org/jira/browse/FLINK-21620

[jira] [Created] (FLINK-21617) FLIP-162: Consistent Flink SQL time function behavior

Leonard Xu created FLINK-21617: -- Summary: FLIP-162: Consistent Flink SQL time function behavior Key: FLINK-21617 URL: https://issues.apache.org/jira/browse/FLINK-21617 Project: Flink Issue Type

[RESULT][VOTE] FLIP-162: Consistent Flink SQL time function behavior

Hi all, The voting time for FLIP-162 has passed. I'm closing the vote now. There were 4 +1 votes, 4 of which are binding: - Jark (binding) - Timo (binding) - Kurt (binding) - Jingsong (binding) There were no -1 votes, thus, FLIP-162 has been accepted. Thanks everyone! Best, Leonard

Re: [DISCUSS] Deprecation and removal of the legacy SQL planner

+1 for the roadmap. Thanks Timo for driving this. Best, Leonard > 在 2021年3月4日，20:40，Timo Walther 写道： > > Last call for feedback on this topic. > > It seems everyone agrees to finally complete FLIP-32. Since FLIP-32 has been > accepted for a very long time, I think we don't need another

[jira] [Created] (FLINK-21575) Replace InputFormat with BulkFormat in HivePartition Reader

Leonard Xu created FLINK-21575: -- Summary: Replace InputFormat with BulkFormat in HivePartition Reader Key: FLINK-21575 URL: https://issues.apache.org/jira/browse/FLINK-21575 Project: Flink

Re: [VOTE] FLIP-163: SQL Client Improvements

+1 (non-binding) The updated FLIP looks well. Best, Leonard > 在 2021年3月2日，22:27，Shengkai Fang 写道： > > already updated the FLIP[2]. It seems the vote has lasted for a long time.

[VOTE] FLIP-162: Consistent Flink SQL time function behavior

Hi all, I would like to start the vote for FLIP-162 [1], which has been discussed and reached a consensus in the discussion thread [2]. Please vote +1 to approve the FLIP, or -1 with a comment. The vote will be open until March 5th (72h), unless there is an objection or not enough votes.

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

ll update this tip to FLIP-162 future plan section as well. If all of us have no more opinions, I’d like start a VOTE thread. Best, Leonard > On 01.03.21 12:59, Leonard Xu wrote: >> Thanks Kurt and Timo for the feedbacks. >>>> I prefer to not introduce such config until

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

or your first approach by having [query-start, >>>> row, auto] as configuration parameters where [auto] is the default? >>>> >>>> This sounds like a good consensus where everyone is happy, no? >>>> >>>> This also allows user to restore

Re: [DISCUSS]FLIP-163: SQL Client Improvements

Hi, all Look like there’s only one divergence about option [ table | sql-client ].dml-sync in this thread, correct me if I’m wrong. 1. Leaving the context of this thread, from a user's perspective, the table.xx configurations should take effect in Table API & SQL, the sql-client.xx

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

way, We don’t have to introduce an obscure configuration prematurely while making all users happy How do you think? Best, Leonard [1] https://docs.aws.amazon.com/kinesisanalytics/latest/sqlref/sql-reference-current-row-timestamp.html > Hope this helps, > > Thanks, > Joe > >> O

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

-- semantics per record > >>>>>> > >>>>>> OR > >>>>>> > >>>>>> SYS_CURRENT_TIMESTAMP -- semantics per record > >>>>>> > >>>>>> > >>>>>> Please check how other v

Re: [ANNOUNCE] Welcome Roman Khachatryan a new Apache Flink Committer

Congrats Roman! Best, Leonard > 在 2021年2月18日，11:10，Yu Li 写道： > > Congratulations, Roman! > > Best Regards, > Yu > > > On Thu, 18 Feb 2021 at 11:05, Xingbo Huang wrote: > >> Congratulations Roman! >> >> Best, >> Xingbo >> >> Yang Wang 于2021年2月18日周四 上午10:29写道： >> >>> Congrats Roman! >>>

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

& reviewing. Make >> technique >> discussion and coding more pipelined will improve efficiency. >> Best, >> Kurt >> On Sat, Jan 30, 2021 at 3:47 PM Leonard Xu wrote: >>> Hi, Timo >>> >>>> I do think that this topic must be part of t

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

in unification aspects by default. > > What do you think? > > Regards, > Timo > > On 28.01.21 16:51, Leonard Xu wrote: >> Hi, Timo >>> I'm sorry that I need to open another discussion thread befoe voting but I >>> think we should also discuss th

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

es.apache.org/jira/browse/FLINK-17868 <https://issues.apache.org/jira/browse/FLINK-17868> > Regards, > Timo > > > On 28.01.21 13:46, Leonard Xu wrote: >> Hi, Jark >>> I have a minor suggestion: >>> I think we will still suggest users use TIMESTA

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

WITH LOCAL TIME ZONE<=> TIMESTAMP_LTZ TIMESTAMP WITH TIME ZONE <=> TIMESTAMP_TZ (supports them in the future) Best, Leonard > > > > > > On Thu, 28 Jan 2021 at 18:52, Leonard Xu <mailto:x

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

edTimestampType, I >>> think it actually >>> makes sense to support java.sql.Timestamp as well as >>> java.time.LocalDateTime. It also has >>> a slight benefit that we might have a chance to run the udf which took them >>> as input parameter >>> after we ch

[jira] [Created] (FLINK-21183) Support watermark for Hive streaming source

Leonard Xu created FLINK-21183: -- Summary: Support watermark for Hive streaming source Key: FLINK-21183 URL: https://issues.apache.org/jira/browse/FLINK-21183 Project: Flink Issue Type

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

if we think they are similar). >>> >>> Should it always display the date and time in UTC or in the user's time >>> zone? I think this part is the >>> reason that surprised lots of users. If we forget about the type and >>> internal representation of

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

+1 (non-binding) - checked/verified signatures and checksums - built from source code succeeded - checked that there are no missed dependency artifacts - started a cluster, WebUI was accessible, ran a wordcount job , no suspicious log output - tested using SQL Client to submit a simple SQL job

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

urrent session time zone. > > If we would like to design this with less effort required, we could think > about returning TIMESTAMP WITH LOCAL TIME ZONE also for CURRENT_TIMESTAMP. > > > I will try to involve more people into this discussion. > > Thanks, > Timo

Re: [DISCUSS] Correct time-related function behavior in Flink SQL

anks, > Timo > > [1] > https://docs.oracle.com/en/database/oracle/oracle-database/21/sqlrf/Data-Types.html#GUID-E7CA339A-2093-4FE4-A36E-1D09593591D3 > > <https://docs.oracle.com/en/database/oracle/oracle-database/21/sqlrf/Data-Types.html#GUID-E7CA339A-2093-4FE4-A36E-1D09593

[DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

Hello, everyone I want to start the discussion of FLIP-162: Consistent Flink SQL time function behavior[1]. We’ve some initial discussion of several problematic functions in dev mail list[2], and I think it's the right time to resolve them by a FLIP. Currently some time function behaviors

Re: [DISCUSS] Correct time-related function behavior in Flink SQL

> If use the default Flink SQL, the window time range of the >> statistics is incorrect, then the statistical results will naturally be >> incorrect. To zhisheng, sorry to hear that this problem influenced your production jobs, Could you share your SQL pattern? we can have more inputs a

Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer

Congratulations Guowei! Best, Leonard

Re: [Announce] SQL docs are now Blink only

Thanks Seth for the Great job ! As the Blink planner has been the default planner and legacy planner is on the way to remove, it makes our document clearer. Best, Leonard > 在 2021年1月19日，23:48，Till Rohrmann 写道： > > Awesome. Thanks a lot Seth! This will help us to keep the docs more easily >

Re: [DISCUSS] Correct time-related function behavior in Flink SQL

job/src/main/resources/pictures/CURRRENT_TIMESTAMP.png> > 在 2021年1月19日，16:22，Leonard Xu 写道： > > Hi, all > > I want to start the discussion about correcting time-related function > behavior in Flink SQL, this is a tricky topic but I think it’s time to > address it. &

Re: [Vote] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo

+1 Best, Leonard > 在 2021年1月19日，17:32，David Anderson 写道： > > +1 > > David > > On Tue, Jan 19, 2021 at 5:28 AM Forward Xu wrote: > >> +1 >> >> Dian Fu 于2021年1月19日周二 上午11:40写道： >> >>> +1 >>> 在 2021年1月19日，上午11:34，Jark Wu 写道： +1 On Tue, 19 Jan 2021 at 01:59,

[DISCUSS] Correct time-related function behavior in Flink SQL

Hi, all I want to start the discussion about correcting time-related function behavior in Flink SQL, this is a tricky topic but I think it’s time to address it. Currently some temporal function behaviors are wired to users. 1. When users use a PROCTIME() in SQL, the value of PROCTIME() has a

[jira] [Created] (FLINK-20983) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 60000milliseconds while awaiting InitProducerId

Leonard Xu created FLINK-20983: -- Summary: FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 6milliseconds while awaiting InitProducerId Key: FLINK-20983 URL

Re: [VOTE] Release 1.12.1, release candidate #2

+1 (non-binding) - checked/verified signatures and hashes - built from source code with scala 2.11 success - checked that there are no missing artifacts - started a cluster, ran a wordcount job, no suspicious log output - tested using SQL Client to submit a simple SQL job and the query result is

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

Congratulations Danny! Best, Leonard > 在 2021年1月12日，19:44，Wei Zhong 写道： > > Congratulations Danny! > > Best, > Wei > >> 在 2021年1月12日，19:09，hailongwang <18868816...@163.com> 写道： >> >> Congratulations Danny! >> >> Best, >> Hailong在 2021-01-12 17:05:31，"Jark Wu" 写道： >>> Congratulations Danny!

[jira] [Created] (FLINK-20940) The LOCALTIME/LOCALTIMSTAMP functions should use session time zone

Leonard Xu created FLINK-20940: -- Summary: The LOCALTIME/LOCALTIMSTAMP functions should use session time zone Key: FLINK-20940 URL: https://issues.apache.org/jira/browse/FLINK-20940 Project: Flink

[jira] [Created] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

Leonard Xu created FLINK-20840: -- Summary: Projection pushdown doesn't work in temporal(lookup) join Key: FLINK-20840 URL: https://issues.apache.org/jira/browse/FLINK-20840 Project: Flink Issue

Re: [DISCUSS] Make Temporal Join syntax easier to use

Hi, Shuo Cheng Thanks for bringing this topic, I think it’s a good idea to simplify current temporal join syntax. But I think the most valuable thing is to simplify the long keyword FOR SYSTEM_TIME AS OF lying in FOR SYSTEM_TIME AS OF L.PROCTIME syntax rather than simplify the L.PROCTIME

[jira] [Created] (FLINK-20746) Support ignore-first-line option for CSV format

Leonard Xu created FLINK-20746: -- Summary: Support ignore-first-line option for CSV format Key: FLINK-20746 URL: https://issues.apache.org/jira/browse/FLINK-20746 Project: Flink Issue Type

Re: [VOTE] Release 1.11.3, release candidate #2

+1 (non-binding) - checked/verified signatures and hashes - built from source code with scala 2.11 succeeded - started a cluster, WebUI was accessible, submitted a wordcount job and ran succeeded - test simple sql job in SQL Client, the query result is expected Best, Leonard Xu > 在 2020年12

Re: [ANNOUNCE] Apache Flink 1.12.0 released

Thanks Dian and Robert for the great work as release manager ! And thanks everyone who makes the release possible ! Best, Leonard > 在 2020年12月10日，20:17，Robert Metzger 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.12.0, which is the latest

Re: [DISCUSS] Make SQL docs Blink only

+1 Very good proposal, blink planner has been the default planner since Flink 1.11.0, and many new features are not supported in legacy planner. Best, Leonard > 在 2020年12月9日，05:15，Arvid Heise 写道： > > +1, add a small info box about legacy planner and point to 1.11 doc > (nothing should have

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

to submit job and the query result is expected - tested read/write from/to sql kafka/upsert-kafka connector in SQL Client - tested read/write/join hvie table in SQL Client Best, Leonard Xu > 在 2020年12月7日，11:17，Guowei Ma 写道： > > +1(non-binding) > - build from source > - build

[jira] [Created] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

Leonard Xu created FLINK-20502: -- Summary: Reduce the uploading time of hadoop jars in hbase e2e test Key: FLINK-20502 URL: https://issues.apache.org/jira/browse/FLINK-20502 Project: Flink

[jira] [Created] (FLINK-20484) Improve hive temporal table exception

Leonard Xu created FLINK-20484: -- Summary: Improve hive temporal table exception Key: FLINK-20484 URL: https://issues.apache.org/jira/browse/FLINK-20484 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20405) The LAG function in over window is not implements correctly

Leonard Xu created FLINK-20405: -- Summary: The LAG function in over window is not implements correctly Key: FLINK-20405 URL: https://issues.apache.org/jira/browse/FLINK-20405 Project: Flink

[jira] [Created] (FLINK-20385) Allow to read metadata for Canal-json format

Leonard Xu created FLINK-20385: -- Summary: Allow to read metadata for Canal-json format Key: FLINK-20385 URL: https://issues.apache.org/jira/browse/FLINK-20385 Project: Flink Issue Type: New

[jira] [Created] (FLINK-20316) update the deduplication section of query page

Leonard Xu created FLINK-20316: -- Summary: update the deduplication section of query page Key: FLINK-20316 URL: https://issues.apache.org/jira/browse/FLINK-20316 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-20279) Elasticsearch6DynamicSinkITCase failed caused by pulling docker image error

Leonard Xu created FLINK-20279: -- Summary: Elasticsearch6DynamicSinkITCase failed caused by pulling docker image error Key: FLINK-20279 URL: https://issues.apache.org/jira/browse/FLINK-20279 Project

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

+1 to stop using bash scripts, and I also have experienced the bash scripts that is really hard to maintain and debug, thanks @Robert for the great work again. I think testcontainers is a nice candidate. Best, Leonard > 在 2020年11月18日，19:46，Aljoscha Krettek 写道： > > +1 > > And I want to

[jira] [Created] (FLINK-20184) update hive streaming read and temporal table documents

Leonard Xu created FLINK-20184: -- Summary: update hive streaming read and temporal table documents Key: FLINK-20184 URL: https://issues.apache.org/jira/browse/FLINK-20184 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu

Congratulations! Congxian Best, Leonard > 在 2020年10月29日，20:55，Stephan Ewen 写道： > > Congrats, Congxian! > > On Thu, Oct 29, 2020 at 12:21 PM Shawn Huang wrote: > >> Congratulations! >> >> Best, >> Shawn Huang >> >> >> hailongwang <18868816...@163.com> 于2020年10月29日周四 下午7:11写道： >> >>>

[jira] [Created] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

Leonard Xu created FLINK-19881: -- Summary: Optimize temporal join with upsert-Source(upsert-kafka) Key: FLINK-19881 URL: https://issues.apache.org/jira/browse/FLINK-19881 Project: Flink Issue

[jira] [Created] (FLINK-19878) Improve watermark ChangelogNormalize for upsertSource

Leonard Xu created FLINK-19878: -- Summary: Improve watermark ChangelogNormalize for upsertSource Key: FLINK-19878 URL: https://issues.apache.org/jira/browse/FLINK-19878 Project: Flink Issue Type

[jira] [Created] (FLINK-19830) Properly implements processing-time temporal table join

Leonard Xu created FLINK-19830: -- Summary: Properly implements processing-time temporal table join Key: FLINK-19830 URL: https://issues.apache.org/jira/browse/FLINK-19830 Project: Flink Issue

Re: [DISCUSS] Release 1.12 Feature Freeze

+1 for **Sunday night**. Best Leonard > 在 2020年10月20日，19:03，Jingsong Li 写道： > > +1 for Sunday night. This also helps Filesystem and Hive implementation for > FLIP-27 Source. And the implementation will block "Support Multiple Input > for Blink Planner". Multiple input is very important for

[jira] [Created] (FLINK-19734) Add scan-only TableSoure tests

Leonard Xu created FLINK-19734: -- Summary: Add scan-only TableSoure tests Key: FLINK-19734 URL: https://issues.apache.org/jira/browse/FLINK-19734 Project: Flink Issue Type: Sub-task

<    1   2   3   4   5   6   7   >