[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

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 maj

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

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 seco

[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写道： >> >>> Congra

[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 Ba

[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

Re: [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces

+1 Best, Leonard > 在 2020年10月16日，11:01，Jark Wu 写道： > > +1 > > On Fri, 16 Oct 2020 at 10:27, admin <17626017...@163.com> wrote: > >> +1 >> >>> 2020年10月16日 上午10:05，Danny Chan 写道： >>> >>> +1, nice job ! >>> >>> Best, >>> Danny Chan >>> 在 2020年10月15日 +0800 PM8:08，Jingsong Li ，写道： Hi all,

[jira] [Created] (FLINK-19644) Support read specific partition of Hive table in temporal join

Leonard Xu created FLINK-19644: -- Summary: Support read specific partition of Hive table in temporal join Key: FLINK-19644 URL: https://issues.apache.org/jira/browse/FLINK-19644 Project: Flink

Re: [ANNOUNCE] New PMC member: Zhu Zhu

Congratulations Zhu Zhu! Best Leonard > 在 2020年10月6日，14:52，Yuan Mei 写道： > > Congrats, Zhu Zhu :-) > > Best > Yuan > > On Tue, Oct 6, 2020 at 1:54 PM Dian Fu wrote: > >> Congratulations Zhu Zhu! >> >> Regards, >> Dian >> >>> 在 2020年10月6日，下午12:05，Yu Li 写道： >>> >>> Congrats and welcome, Zh

Re: [DISCUSS] Move Hive document to "Table & SQL Connectors" from "Table API & SQL"

+1 > 在 2020年9月24日，21:54，Seth Wiesman 写道： > > +1 > > On Thu, Sep 24, 2020 at 2:49 AM Rui Li wrote: > >> +1 >> >> On Thu, Sep 24, 2020 at 2:59 PM Timo Walther wrote: >> >>> +1 >>> >>> On 24.09.20 06:54, Jark Wu wrote: +1 to move it there. On Thu, 24 Sep 2020 at 12:16, Jingso

[jira] [Created] (FLINK-19342) stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23

Leonard Xu created FLINK-19342: -- Summary: stop overriding convertFrom() in FlinkPlannerImpl after upgrade calcite to 1.23 Key: FLINK-19342 URL: https://issues.apache.org/jira/browse/FLINK-19342 Project

[jira] [Created] (FLINK-19271) wrong HOP_PROCTIME output when materialize proctime

Leonard Xu created FLINK-19271: -- Summary: wrong HOP_PROCTIME output when materialize proctime Key: FLINK-19271 URL: https://issues.apache.org/jira/browse/FLINK-19271 Project: Flink Issue Type

Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He

Congratulations! Godfrey Best, Leonard > 在 2020年9月16日，13:12，Yangze Guo 写道： > > Congratulations! Xiaoling. > > Best, > Yangze Guo > > On Wed, Sep 16, 2020 at 12:45 PM Dian Fu wrote: >> >> Congratulations, well deserved! >> >> Regards, >> Dian >> >>> 在 2020年9月16日，下午12:36，Guowei Ma 写道： >>>

Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang

Congrats, Yun! Best, Leonard > 在 2020年9月15日，19:01，Yangze Guo 写道： > > Congrats, Yun!

Re: [ANNOUNCE] New Apache Flink Committer - Arvid Heise

Congrats! Arvid. Best, Leonard > 在 2020年9月15日，16:23，Paul Lam 写道： > > Congrats, Arvid! > > Best, > Paul Lam > >> 2020年9月15日 15:29，Jingsong Li 写道： >> >> Congratulations Arvid ! >> >> Best, >> Jingsong >> >> On Tue, Sep 15, 2020 at 3:27 PM Dawid Wysakowicz >> wrote: >> >>> Congratulations

Re: [VOTE] FLIP-107: Handling of metadata in SQL connectors

+1(non-binding) Leonard > 在 2020年9月12日，21:46，Danny Chan 写道： > > +1, non-binding ~ > > Konstantin Knauf 于2020年9月11日 周五上午2:04写道： > >> +1 (binding) >> >> >> >> On Thu, Sep 10, 2020 at 4:29 PM Dawid Wysakowicz >> >> wrote: >> >> >> >>> +1 (binding) >> >>> >> >>> On 10/09/2020 14:03, Al

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

timestamp INT METADATA [FROM >>>>>>>>> 'my-timestamp-field'] [VIRTUAL] >>>>>>>>> Especially I like the shortcut: timestamp INT METADATA, this makes >>>>>> the >>>>>>>>> most >>

Re: [ANNOUNCE] New Apache Flink Committer - Niels Basjes

Congrats, Niels! Best, Leonard > 在 2020年9月15日，05:29，Peter Huang 写道： > > Congratulations, Niels!! > > > On Mon, Sep 14, 2020 at 2:28 PM Caito Scherr wrote: > >> Congratulations, Niels!! >> >> On Mon, Sep 14, 2020 at 1:37 AM Robert Metzger >> wrote: >> >>> Hi all, >>> >>> >>> >>> On beha

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

; optional >>>>>>> when >>>>>>> you are accessing a read-only metadata. Because: >>>>>>> 1. The "timestamp INT METADATA" should be a normal column, because >>>>>>> "METADATA" is just a modifier to indicate it

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

;>>>>>>> "slightly rejected alternative". >>>>>>>> >>>>>>>> Furthermore, we would need to think about how such a new design >>>>>>>> influences the LIKE clause though. >>>>>>>> >>>>&

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

computed column syntax >> but >>>> have >>>>>>> different semantics >>>>>>> would confuse users a lot. >>>>>>> >>>>>>> Besides, I think metadata fields are conceptually not the same with >>&

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

ed column >>> receives a valid data type when constructing the table schema. >>> >>> "I don't see a reason why `DecodingFormat#applyReadableMetadata` needs a >>> DataType argument." >>> >>> Correct he DeserializationSchema doesn&

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

Hi, Timo Thanks for you explanation and update, I have only one question for the latest FLIP. About the MAP DataType of key 'debezium-json.source', if user want to use the table name metadata, they need to write: tableName STRING AS CAST(SYSTEM_METADATA('debeuim-json.source') AS MAP)['table'

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

Ignore my question(4), I’ve found the answer in the doc : 'value.fields-include' = ‘EXCEPT_KEY' (all fields of the schema minus fields of the key) > 在 2020年9月7日，16:33，Leonard Xu 写道： > > (4) About Reading and writing from key and value section, we bind that the &

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

Thanks Timo for the update ! I like the proposal in general, I have some question about the doc. (1) About the DDL `CAST(SYSTEM_METADATA("offset") AS INT)`, It looks like we use `CAST` to resolve the nullability of meta column type, Could we use explicit type (i.e. SYSTEM_METADATA("offset”) INT

[jira] [Created] (FLINK-19148) Table crashed in Flink Table API & SQL Docs

Leonard Xu created FLINK-19148: -- Summary: Table crashed in Flink Table API & SQL Docs Key: FLINK-19148 URL: https://issues.apache.org/jira/browse/FLINK-19148 Project: Flink Issue Type:

[jira] [Created] (FLINK-19094) Revise the description watermark strategy in Flink Table document

Leonard Xu created FLINK-19094: -- Summary: Revise the description watermark strategy in Flink Table document Key: FLINK-19094 URL: https://issues.apache.org/jira/browse/FLINK-19094 Project: Flink

[jira] [Created] (FLINK-19092) Parse comment on computed column failed

Leonard Xu created FLINK-19092: -- Summary: Parse comment on computed column failed Key: FLINK-19092 URL: https://issues.apache.org/jira/browse/FLINK-19092 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19082) Add docs for temporal table and temporal table join

Leonard Xu created FLINK-19082: -- Summary: Add docs for temporal table and temporal table join Key: FLINK-19082 URL: https://issues.apache.org/jira/browse/FLINK-19082 Project: Flink Issue Type

[jira] [Created] (FLINK-19081) Deprecate TemporalTableFunction and Table$createTemporalTableFunction()

Leonard Xu created FLINK-19081: -- Summary: Deprecate TemporalTableFunction and Table$createTemporalTableFunction() Key: FLINK-19081 URL: https://issues.apache.org/jira/browse/FLINK-19081 Project: Flink

[jira] [Created] (FLINK-19080) Materialize timeindicator data type in the right input of temporal join

Leonard Xu created FLINK-19080: -- Summary: Materialize timeindicator data type in the right input of temporal join Key: FLINK-19080 URL: https://issues.apache.org/jira/browse/FLINK-19080 Project: Flink

[jira] [Created] (FLINK-19079) Support row time deduplicate operator

Leonard Xu created FLINK-19079: -- Summary: Support row time deduplicate operator Key: FLINK-19079 URL: https://issues.apache.org/jira/browse/FLINK-19079 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19078) Import rowtime join temporal operator

Leonard Xu created FLINK-19078: -- Summary: Import rowtime join temporal operator Key: FLINK-19078 URL: https://issues.apache.org/jira/browse/FLINK-19078 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19076) Import rule to deal Temporal Join condition

Leonard Xu created FLINK-19076: -- Summary: Import rule to deal Temporal Join condition Key: FLINK-19076 URL: https://issues.apache.org/jira/browse/FLINK-19076 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19077) Improve process time temporal join operator

Leonard Xu created FLINK-19077: -- Summary: Improve process time temporal join operator Key: FLINK-19077 URL: https://issues.apache.org/jira/browse/FLINK-19077 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19075) Infer changelog trait for temporal join node

Leonard Xu created FLINK-19075: -- Summary: Infer changelog trait for temporal join node Key: FLINK-19075 URL: https://issues.apache.org/jira/browse/FLINK-19075 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19074) Materialize timeindicator in the right input of temporal join

Leonard Xu created FLINK-19074: -- Summary: Materialize timeindicator in the right input of temporal join Key: FLINK-19074 URL: https://issues.apache.org/jira/browse/FLINK-19074 Project: Flink

[jira] [Created] (FLINK-19073) Improve streamExecTemporalJoinRule

Leonard Xu created FLINK-19073: -- Summary: Improve streamExecTemporalJoinRule Key: FLINK-19073 URL: https://issues.apache.org/jira/browse/FLINK-19073 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19072) Import Temporal Table join rule

Leonard Xu created FLINK-19072: -- Summary: Import Temporal Table join rule Key: FLINK-19072 URL: https://issues.apache.org/jira/browse/FLINK-19072 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-132: Temporal Table DDL and Temporal Table Join

t; > > Best, > > Jark > > > > On Tue, 25 Aug 2020 at 01:41, Fabian Hueske > <mailto:fhue...@gmail.com>> wrote: > > > >> Leonard, Thanks for updating the FLIP! > >> > >> +1 to the current version. > >> > >> Thanks,

[jira] [Created] (FLINK-19063) Support join late event from dimension table side in temporal table join

Leonard Xu created FLINK-19063: -- Summary: Support join late event from dimension table side in temporal table join Key: FLINK-19063 URL: https://issues.apache.org/jira/browse/FLINK-19063 Project: Flink

Re: [ANNOUNCE] New PMC member: Dian Fu

Congrats, Dian! Well deserved. Best Leonard > 在 2020年8月27日，19:34，Kurt Young 写道： > > Congratulations Dian! > > Best, > Kurt > > > On Thu, Aug 27, 2020 at 7:28 PM Rui Li wrote: > >> Congratulations Dian! >> >> On Thu, Aug 27, 2020 at 5:39 PM Yuan Mei wrote: >> >>> Congrats! >>> >>> On T

Re: [ANNOUNCE] Apache Flink 1.10.2 released

Thanks ZhuZhu for being the release manager and everyone who contributed to this release. Best, Leonard

[VOTE] FLIP-132: Temporal Table DDL and Temporal Table Join

Hi all, I would like to start the vote for FLIP-132 [1], which has been discussed and reached a consensus in the discussion thread [2]. The vote will be open until 27th August (72h), unless there is an objection or not enough votes. Best, Leonard [1] https://cwiki.apache.org/confluence/display

Re: [DISCUSS] FLIP-132: Temporal Table DDL

oin". > I'm also fine with Rui's proposal that "temporal join" can also work with a > regular table. > > Best, > Jark > > On Fri, 21 Aug 2020 at 23:49, Leonard Xu <mailto:xbjt...@gmail.com>> wrote: > Thanks @Fabian @Jark @Rui for sharing y

Re: [DISCUSS] FLIP-132: Temporal Table DDL

rsion concept in regular table. > > > In my understanding access to a table's history is the core property of > temporal tables (that's also how temporal tables are defined for SQL Server > [1] or PostgreSQL [2]). > A "temporal table without versions"or "la

Re: [DISCUSS] FLIP-132: Temporal Table DDL

If we agree regular tables are temporal table, I tend to keep latest-only temporal table to clarify the temporal and version concept in regular table. Best Leonard > Cheers, > Fabian > > Am Mi., 19. Aug. 2020 um 04:24 Uhr schrieb Leonard Xu <mailto:xbjt...@gmail.com>>: &

Re: [DISCUSS] FLIP-132: Temporal Table DDL

oins" into something else that does not imply a versioning. >> Maybe we can call them just lookup joins to avoid introducing another term? >> >> Thanks, Fabian >> >> Am Di., 18. Aug. 2020 um 04:30 Uhr schrieb Rui Li : >> >>> Thanks Leonard for th

Re: [DISCUSS] FLIP-132: Temporal Table DDL

append-only table source with event-time and PK, > will I be allowed to do an event-time temporal join with this table? Yes, I list some examples in the doc, the example versioned_rates3 is this case exactly. Best Leonard > > On Wed, Aug 12, 2020 at 3:31 PM Leonard Xu <mailto:x

[jira] [Created] (FLINK-18976) Support user defined query in JDBC Source

Leonard Xu created FLINK-18976: -- Summary: Support user defined query in JDBC Source Key: FLINK-18976 URL: https://issues.apache.org/jira/browse/FLINK-18976 Project: Flink Issue Type

Re: [ANNOUNCE] New Flink Committer: David Anderson

Congratulations! David Best Leonard > 在 2020年8月12日，15:59，Till Rohrmann 写道： > > Congratulations, David!

Re: 来自kris18的邮件

Hi Just send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev mailto:dev@flink.apache.org>>, and you can refer[1] for more details. Best, Leonard [1]https://flink.apache.org/community.html#mailing-lists

Re: [DISCUSS] FLIP-132: Temporal Table DDL

<https://cwiki.apache.org/confluence/display/FLINK/FLIP-132+Temporal+Table+DDL> > 在 2020年8月4日，21:25，Leonard Xu 写道： > > Hi, all > > I’ve updated the FLIP[1] with the terminology `ChangelogTime`. > > Best > Leonard > [1] > https://cwiki.apache.org/conflu

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

+1 for FLIP-107 Reading different parts of source code should be the key feature for Flink SQL, like metadata in CDC data, key and timestamp in Kafka records. The scope of FLIP-107 is too big to finish in one version IMO, maybe we can start part work in 1.12. Best Leonard > 在 2020年8月11日，19:5

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

connector will lose the timely support from Flink community in my opinion, I’m slightly -1 for this. Best Leonard Xu > 在 2020年8月11日，02:36，Márton Balassi 写道： > > Hi All, > > I am also fairly torn on this one, however unless we are vigilant in keeping > the flink repository r

Re: [VOTE] FLIP-132: Temporal Table DDL

Thanks godfrey and all involved. The vote is cancelled because there’re some new inputs and insufficient votes, We have some new inputs after discussed with Jark and Kurt offline, I’ll update the FLIP doc ASAP and start a new discussion thread. Sorry for the cancel. Best regards, Leonard Xu

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Hi, all I’ve updated the FLIP[1] with the terminology `ChangelogTime`. Best Leonard [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-132+Temporal+Table+DDL <https://cwiki.apache.org/confluence/display/FLINK/FLIP-132+Temporal+Table+DDL> > 在 2020年8月4日，20:58，Leonard Xu 写道

Re: [DISCUSS] FLIP-132: Temporal Table DDL

time for now, so I tend to do not expose the concept to users. Best, Leonard > > On 04.08.20 04:58, Leonard Xu wrote: >> Thanks Konstantin, >> Regarding your questions, hope my comments has address your questions and I >> also add a few explanation in the FLIP. >

[VOTE] FLIP-132: Temporal Table DDL

Hi all, I would like to start the vote for FLIP-132 [1], which has been discussed and reached a consensus in the discussion thread [2]. The vote will be open until 7th August (72h), unless there is an objection or not enough votes. Best, Leonard [1] https://cwiki.apache.org/confluence/display/

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Do., 30. Juli 2020 um 22:15 Uhr schrieb Seth Wiesman < >>> sjwies...@gmail.com >>>> : >>> >>>> Hi Leondard, >>>> >>>> Thank you for pushing this, I think the updated syntax looks really >> good >>>> and the sema

[jira] [Created] (FLINK-18768) Imporve SQL kafka connector docs about passing kafka properties

Leonard Xu created FLINK-18768: -- Summary: Imporve SQL kafka connector docs about passing kafka properties Key: FLINK-18768 URL: https://issues.apache.org/jira/browse/FLINK-18768 Project: Flink

[jira] [Created] (FLINK-18759) Add readme.md for TPC-DS tools

Leonard Xu created FLINK-18759: -- Summary: Add readme.md for TPC-DS tools Key: FLINK-18759 URL: https://issues.apache.org/jira/browse/FLINK-18759 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18758) Support debezium data type in debezium format

Leonard Xu created FLINK-18758: -- Summary: Support debezium data type in debezium format Key: FLINK-18758 URL: https://issues.apache.org/jira/browse/FLINK-18758 Project: Flink Issue Type

Re: [DISCUSS] FLIP-132: Temporal Table DDL

Hi, Konstantin > > 1) A "Versioned Temporal Table DDL on source" can only be joined on the > PRIMARY KEY attribute, correct? Yes, the PRIMARY KEY would be join key. > > 2) Isn't it the time attribute in the ORDER BY clause of the VIEW definition > that defines > whether a event-time or proces

Re: flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗

>, if you prefer Chinese, please discuss question in user...@flink.apache.org <mailto:user...@flink.apache.org> , you can refer[1] for more details. > 在 2020年7月29日，14:33，Leonard Xu 写道： > > Hi, taochabglian > > The u...@flink.apache.org <mailto:u...@flink.apache.org>

Re: flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗

f you prefer Chinese, please discuss question in user...@flink.apache.org <mailto:user...@flink.apache.org> , you can refer[1] for more details. Best Leonard Xu [1] https://flink.apache.org/community.html#mailing-lists <https://flink.apache.org/community.html#mailing-lists> >

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

more of a bikeshedding question than a blocker and I look >> forward to seeing what you come up with! >> >> Seth >> >> On Mon, Jul 6, 2020 at 10:59 AM Benchao Li wrote: >> >>> Hi everyone, >>> >>> Thanks a lot for the great discuss

[DISCUSS] FLIP-132: Temporal Table DDL

Hello everyone, Currently, user can correlate temporal table by temporal table join to enrich their fact table, a temporal table can be a changing history table which tracks the changes(e.g. database changelog) or a changing dimensioned table which materializes the changes(e.g. database table)

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

Thanks Jark +1(non-binding) Best Leonard > 在 2020年7月27日，15:32，jincheng sun 写道： > > +1（binding) > > Best, > Jincheng > > > Jark Wu 于2020年7月27日周一 上午10:01写道： > >> +1 (binding) >> >> On Fri, 24 Jul 2020 at 22:22, Timo Walther wrote: >> >>> +1 >>> >>> Thanks for driving this Jark. >>> >>>

[jira] [Created] (FLINK-18700) Debezium-json format throws Exception when PG table's IDENTITY config is not FULL

Leonard Xu created FLINK-18700: -- Summary: Debezium-json format throws Exception when PG table's IDENTITY config is not FULL Key: FLINK-18700 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

Thanks Jark for the update. The latest FLIP looks well. I like Dawid’s proposal of TableDescriptor. Best Leonard Xu > 在 2020年7月23日，22:56，Jark Wu 写道： > > Hi Timo, > > That's a good point I missed in the design. I have updated the FLIP and added > a note under the `Kaf

Re: [ANNOUNCE] Apache Flink 1.11.1 released

Congratulations! Thanks Dian Fu for the great work as release manager, and thanks everyone involved! Best Leonard Xu > 在 2020年7月22日，14:52，Dian Fu 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.11.1, which is the first bugfix rel

Re: subscribe dev mail list

Hi, Jake Just send email to dev-subscr...@flink.apache.org <mailto:dev-subscr...@flink.apache.org> if you want to subscribe the mail from dev@flink.apache.org <mailto:dev@flink.apache.org> , and you can refer[1] for more details. Best, Leonard Xu [1]https://flink.apache.org/co

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

+1 (non-binding) - checked/verified signatures and hashes - built from source code with scala 2.11 succeeded - checked that there are no missing artifacts - started a cluster, the Web UI was accessible, submitted a wordcount job and ran succeeded, no suspicious log output - test using SQL Client

Re: [DISCUSS] FLIP-129: Refactor Descriptor API to register connector in Table API

gOptions .key("fail-on-missing-field") .booleanType() .defaultValue(false) WDYT? Best, Leonard Xu > 在 2020年7月15日，16:37，Timo Walther 写道： > > Hi Jark, > > thanks for working on this issue. It is time to fix this last part of > inconsisten

[jira] [Created] (FLINK-18604) HBase Descriptor can not work in Table API

Leonard Xu created FLINK-18604: -- Summary: HBase Descriptor can not work in Table API Key: FLINK-18604 URL: https://issues.apache.org/jira/browse/FLINK-18604 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18585) Dynamic index can not work in new DynamicTableSink

Leonard Xu created FLINK-18585: -- Summary: Dynamic index can not work in new DynamicTableSink Key: FLINK-18585 URL: https://issues.apache.org/jira/browse/FLINK-18585 Project: Flink Issue Type

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

Thanks Dian for the work, I’m fine with do not include FLINK-17726 in this bug-fix version. Best, Leonard Xu > 在 2020年7月13日，11:31，Dian Fu 写道： > > Hi all, > > I have gone over the issues mentioned in this thread and most issues have > already been resolved. Thanks you all

[jira] [Created] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

Leonard Xu created FLINK-18548: -- Summary: Improve FlinkCalcMergeRule to merge calc nodes better Key: FLINK-18548 URL: https://issues.apache.org/jira/browse/FLINK-18548 Project: Flink Issue Type

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

4 Can not select fields with JdbcCatalog - FLINK-17726 Scheduler should take care of tasks directly canceled by TaskManager - FLINK-17075 Add task status reconciliation between TM and JM So, +1 to prepare a quick bug-fix version from my side. Best, Leonard Xu [1] user: http://apache-flink

Re: [ANNOUNCE] Apache Flink 1.11.0 released

Congratulations! Thanks Zhijiang and Piotr for the great work, and thanks everyone involved! Best, Leonard Xu

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

Congratulations Piotr! Best, Leonard Xu > 在 2020年7月7日，07:06，Jeff Zhang 写道： > > Congratulations Piotr! > > Thomas Weise 于2020年7月7日周二 上午4:45写道： > >> Congratulations! >> >> >> On Mon, Jul 6, 2020 at 10:58 AM Seth Wiesman wrote: >> >>&g

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

poral Table Function and will not introduce more concept and works. Jark, Jingsong, Konstantin, WDYT? Best, Leonard Xu [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-107%3A+Reading+table+columns+from+different+parts+of+source+records#FL

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

time and it may lead an incorrect result for user in some scenarios. If the percentage is highly enough and most user cases can accept the approximate event time, I'm ok to support it for usability although it doesn’t implements the event time semantic strictly. Cheers, Leonard Xu

<    1   2   3   4   5   6   7   8   >