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

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

which will break event time semantics. And we can support it when CDC tools have the ability to obtain/extract the DML operation time. And this has get consensus from me, Jingsong, Jark and Kurt after offline discuss, the opinions from Knauf and Seth looks like same with us. I’

Re: [VOTE] Release 1.11.0, release candidate #4

Kafka (new connector) with some queries in SQL Client, they works well and the result is expected - started a cluster, WebUI was accessible, submitted a wordcount job and ran succeeded, no suspicious log output - the web PR looks good Best, Leonard Xu

[jira] [Created] (FLINK-18439) Update sql client jar url in docs

Leonard Xu created FLINK-18439: -- Summary: Update sql client jar url in docs Key: FLINK-18439 URL: https://issues.apache.org/jira/browse/FLINK-18439 Project: Flink Issue Type: Bug

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

gelog stream. And the rowtime in the changelog stream is the `TUMBLE_ROWTIME` value (just like the `gmt_modified` column in DB). # summary we should use ‘PERIOD FOR SYSTEM_TIME(operation_time) syntax to track history version by operation time rather than rowtime in temporal table scenario. we al

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

Best, >>>>> >>>>> Konstantin >>>>> >>>>> On Mon, Jun 22, 2020 at 10:53 AM Kurt Young >> wrote: >>>>> >>>>>> I agree with Timo, semantic about primary key needs more thought >> and >>>

Re: Could someone help me to review PR[12727]?

Hi, Roc Thanks for the contribution, I’d like to help review this PR. Best, Leonard Xu

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

R SYSTEM_TIME AS OF x") in query. So, I prefer to resolve the small divergence with “CREATE TABLE” which (1) is more unified with our source/sink/temporal dynamic table conceptually, (2) is aligned with current lookup table, (3) also make users learn less keyword. WDYT？ Best, Leonard Xu

[jira] [Created] (FLINK-18342) SQLParser can not parse ROW() if it contains UDF

Leonard Xu created FLINK-18342: -- Summary: SQLParser can not parse ROW() if it contains UDF Key: FLINK-18342 URL: https://issues.apache.org/jira/browse/FLINK-18342 Project: Flink Issue Type

Re: [ANNOUNCE] Yu Li is now part of the Flink PMC

Congratulations Yu ! Best, Leonard Xu > 在 2020年6月17日，09:50，Yangze Guo 写道： > > Congrats, Yu! > Best, > Yangze Guo > > On Wed, Jun 17, 2020 at 9:35 AM Xintong Song wrote: >> >> Congratulations Yu, well deserved~! >> >> Thank you~ >> >&

[jira] [Created] (FLINK-18268) Correct Table API in Temporal table docs

Leonard Xu created FLINK-18268: -- Summary: Correct Table API in Temporal table docs Key: FLINK-18268 URL: https://issues.apache.org/jira/browse/FLINK-18268 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Flink Committer: Benchao Li

Congratulations, Benchao ! Best, Leonard Xu > 在 2020年6月9日，14:36，Jiayi Liao 写道： > > Congratulations! > > > Best, > Jiayi Liao > > On Tue, Jun 9, 2020 at 2:32 PM Dian Fu wrote: > >> Congrats Benchao! >> >> Regards, >

[jira] [Created] (FLINK-18170) E2E tests manually for PostgresCatalog

Leonard Xu created FLINK-18170: -- Summary: E2E tests manually for PostgresCatalog Key: FLINK-18170 URL: https://issues.apache.org/jira/browse/FLINK-18170 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

+1 for Jingsong’s proposal to put flink-csv, flink-json and flink-avro under lib/ directory. I have heard many SQL users(most of newbies) complaint the out-of-box experience in mail list. Best, Leonard Xu > 在 2020年6月5日，14:39，Benchao Li 写道： > > +1 to include them for sql-client b

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

Congratulates Xintong ! Best, Leonard Xu > 在 2020年6月5日，12:47，Benchao Li 写道： > > Congratulations Xintong, well deserved! > > Becket Qin 于2020年6月5日周五 下午12:45写道： > >> Hi all, >> >> On behalf of the PMC, I’m very happy to announce Xintong Song as a new >&g

Re: 订阅 flink 开发列表

se English in dev mail list ^_^. Best, Leonard Xu > On Fri, Jun 5, 2020 at 10:06 AM Jake wrote: > >> 订阅 flink 开发列表

[jira] [Created] (FLINK-18083) DDL TIMESTAMP(9) defined on HBase table lost nano seconds

Leonard Xu created FLINK-18083: -- Summary: DDL TIMESTAMP(9) defined on HBase table lost nano seconds Key: FLINK-18083 URL: https://issues.apache.org/jira/browse/FLINK-18083 Project: Flink Issue

[jira] [Created] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData

Leonard Xu created FLINK-18072: -- Summary: HBaseLookupFunction can not work with new internal data structure RowData Key: FLINK-18072 URL: https://issues.apache.org/jira/browse/FLINK-18072 Project: Flink

[jira] [Created] (FLINK-17932) All hbase config Options can not work in HBaseTableSource

Leonard Xu created FLINK-17932: -- Summary: All hbase config Options can not work in HBaseTableSource Key: FLINK-17932 URL: https://issues.apache.org/jira/browse/FLINK-17932 Project: Flink Issue

[jira] [Created] (FLINK-17890) support in DataType TIMESTAMP_WITH_LOCAL_TIME_ZONE in JDBC

Leonard Xu created FLINK-17890: -- Summary: support in DataType TIMESTAMP_WITH_LOCAL_TIME_ZONE in JDBC Key: FLINK-17890 URL: https://issues.apache.org/jira/browse/FLINK-17890 Project: Flink Issue

Re: [DISCUSS] Semantics of our JIRA fields

Thanks bringing up this topic @Robert, +1 to the proposal. It clarifies the JIRA fields well and should be a rule to follow. Best, Leonard Xu > 在 2020年5月22日，20:24，Aljoscha Krettek 写道： > > +1 That's also how I think of the semantics of the fields. > > Aljoscha > >

Re: [DISCUSS] How to view azure pipeline results and cancel a pipeline?

this helps! > > Best, > Robert > > > > [1] > https://developercommunity.visualstudio.com/content/problem/1038652/third-parties-are-unable-to-access-notification-li-1.html > > <https://developercommunity.visualstudio.com/content/problem/1038652/third-parties-are-unab

Re: 本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群

on, could you post your SQL or program that can reproduce the null issue rather than only a debug information? And we can keep communication in user...@flink.apache.org <mailto:user...@flink.apache.org> if you prefer Chinese. Best, Leonard Xu [1] https://flink.apache.org/

[DISCUSS] How to view azure pipeline results and cancel a pipeline?

trigger a new pipeline, I remembered travis can cancel easily, maybe I did not find the switch yet. Do you meet same problems？and someone has better practice？ Best, Leonard Xu [1] https://dev.azure.com/apache-flink/web/build.aspx?pcguid=2d3c0ac8-fecf-45be-8407-6d87302181a9&builduri=vstfs%3a%2

[jira] [Created] (FLINK-17847) ArrayIndexOutOfBoundsException happened in when codegen StreamExec operator

Leonard Xu created FLINK-17847: -- Summary: ArrayIndexOutOfBoundsException happened in when codegen StreamExec operator Key: FLINK-17847 URL: https://issues.apache.org/jira/browse/FLINK-17847 Project

[jira] [Created] (FLINK-17802) Set offset commit only if group id is configured for new Kafka Table source

Leonard Xu created FLINK-17802: -- Summary: Set offset commit only if group id is configured for new Kafka Table source Key: FLINK-17802 URL: https://issues.apache.org/jira/browse/FLINK-17802 Project

Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary compatible across bug fix releases (x.y.u and x.y.v)

+1 (non-binding) Best, Leonard Xu > 在 2020年5月17日，00:30，Zhu Zhu 写道： > > +1 > > Thanks, > Zhu Zhu > > Yun Tang 于2020年5月16日周六 下午11:18写道： > >> >> +1 (non-binding) >> >> Yun Tang >> >> Fro

Re: [ANNOUNCE] Apache Flink 1.10.1 released

Thanks Yu for being the release manager, and everyone else who made this possible. Best, Leonard Xu > 在 2020年5月18日，10:43，Zhu Zhu 写道： > > Thanks Yu for being the release manager. Thanks everyone who made this > release possible! > > Thanks, > Zhu Zhu > &g

[jira] [Created] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

Leonard Xu created FLINK-17762: -- Summary: Postgres Catalog should pass table's primary key to catalogTable Key: FLINK-17762 URL: https://issues.apache.org/jira/browse/FLINK-17762 Project:

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

wordcount job and ran succeeded, no suspicious log output - the web PR looks good Best, Leonard Xu > 在 2020年5月12日，10:24，jincheng sun 写道： > > +1(binding) > > - built from source and run Streaming word count without unexpected > information. > - check the signatures, looks

[jira] [Created] (FLINK-17614) Add project ITCase for partition table in filesystem connector

Leonard Xu created FLINK-17614: -- Summary: Add project ITCase for partition table in filesystem connector Key: FLINK-17614 URL: https://issues.apache.org/jira/browse/FLINK-17614 Project: Flink

Re: Hope to contribute code

k all code related issues. As a newbie, from my experience. We can start from some simple tasks that marked a label `newbie` or `start` [3]. We can also choose tasks from basic component like `Documentation` or `Test` [4]. Hope this can help you. Best, Leonard Xu [1]https://flink.apach

Re: [DISCUSS]Refactor flink-jdbc connector structure

. I create a jira ticket[2] for flink-hbase, but I think we may need some discussion about the detail of refactor, we could do this in the jira or open another mail thread if necessary. Best, Leonard Xu [1] https://issues.apache.org/jira/browse/FLINK-17537 <https://issues.apache.org/j

[jira] [Created] (FLINK-17538) Refactor flink-hbase connector structure

Leonard Xu created FLINK-17538: -- Summary: Refactor flink-hbase connector structure Key: FLINK-17538 URL: https://issues.apache.org/jira/browse/FLINK-17538 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17537) Refactor flink-jdbc connector structure

Leonard Xu created FLINK-17537: -- Summary: Refactor flink-jdbc connector structure Key: FLINK-17537 URL: https://issues.apache.org/jira/browse/FLINK-17537 Project: Flink Issue Type: Improvement

[DISCUSS]Refactor flink-jdbc connector structure

? Any feedback is appreciate. Best, Leonard Xu [1]http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Remove-registration-of-TableSource-TableSink-in-Table-Env-and-ConnectTableDescriptor-td37270.html <http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISC

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks Dian for the release and being the release manager ! Best， Leonard Xu > 在 2020年4月26日，17:58，Benchao Li 写道： > > Thanks Dian for the effort, and all who make this release possible. Great > work! > > Konstantin Knauf mailto:konstan...@ververica.com>> > 于2020

Re: [DISCUSS] Exact feature freeze date

+ 1 for the feature freeze date Best, Leonard Xu > 在 2020年4月24日，09:32，Jingsong Li 写道： > > +1 > > Best, > Jingsong Lee > > On Fri, Apr 24, 2020 at 2:27 AM Zhu Zhu wrote: > >> +1 for extending the code freeze date. >> FLIP-119 could benefit

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

checked in between 1.9.3 and 1.9.2, make sure all issues set the "fixVersion" property - started a cluster, WebUI was accessible, submitted a wordcount job and ran succeeded, no suspicious log output - the web PR looks good Best, Leonard Xu > 在 2020年4月22日，17:58，Dian Fu 写道： > &

Re: Apply to contribute to Flink

, Leonard Xu [1]: https://flink.apache.org/contributing/contribute-code.html#consensus > 在 2020年4月21日，12:31，Lee Sysuke 写道： > > Hi Guys, > > I want to contribute to Apache Flink.Would you please give me the > permission as a contributor?My JIRA ID is lyee.

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations! Best, Leonard Xu > 在 2020年4月17日，15:46，Benchao Li 写道： > > Congratulations Hequn! > > Stephan Ewen 于2020年4月17日周五 下午3:42写道： > >> Congrats! >> >> On Fri, Apr 17, 2020 at 9:40 AM Jark Wu wrote: >> >>> Congratulations Hequn! &

[jira] [Created] (FLINK-16975) Add docs for FileSystem connector and hive connector

Leonard Xu created FLINK-16975: -- Summary: Add docs for FileSystem connector and hive connector Key: FLINK-16975 URL: https://issues.apache.org/jira/browse/FLINK-16975 Project: Flink Issue Type

Re: [VOTE] FLIP-122: New Connector Property Keys for New Factory

+1 (non-binding) It’s time to simplify connector properties. Best, Leonard Xu > 在 2020年4月3日，10:02，LakeShen 写道： > > +1 (non-binding) > > Benchao Li 于2020年4月3日周五 上午9:50写道： > >> +1 (non-binding) >> >> Dawid Wysakowicz 于2020年4月3日周五 上午12:33写道： >

Re: [DISCUSS] Change default planner to blink planner in 1.11

+1 to make the Blink planner be the planner in 1.11. Blink planner has richer features than legacy planner and stable enough from now. Best, Leonard Xu > 在 2020年4月1日，19:51，Aljoscha Krettek 写道： > > +1 to making Blink the default planner, we definitely don't want to maintain

Re: [ANNOUNCE] New Committers and PMC member

Congratulations Konstantin, Dawid and Zhijiang! Well deserved! Best, Leonard Xu > 在 2020年4月1日，21:22，Jark Wu 写道： > > Congratulations to you all! > > Best, > Jark > > On Wed, 1 Apr 2020 at 20:33, Kurt Young wrote: > >> Congratulations to you all! >> &g

Re: [VOTE] FLIP-95: New TableSource and TableSink interfaces

+1(non-binding) Best, Leonard Xu > 在 2020年3月30日，16:43，Jingsong Li 写道： > > +1 > > Best, > Jingsong Lee > > On Mon, Mar 30, 2020 at 4:41 PM Kurt Young wrote: > >> +1 >> >> Best, >> Kurt >> >> >> On Mon, Mar 30, 2020 at

Re: [VOTE] FLIP-115: Filesystem connector in Table

+1 Best, Leonard > 在 2020年3月28日，16:25，Kurt Young 写道： > > +1 > > Best, > Kurt > > > On Fri, Mar 27, 2020 at 10:51 AM Jingsong Li wrote: > >> Hi everyone, >> >> I'd like to start the vote of FLIP-115 [1], which introduce Filesystem >> table factory in table. This FLIP is discussed in the th

[jira] [Created] (FLINK-16701) Elasticsearch sink support alias for indices.

Leonard Xu created FLINK-16701: -- Summary: Elasticsearch sink support alias for indices. Key: FLINK-16701 URL: https://issues.apache.org/jira/browse/FLINK-16701 Project: Flink Issue Type

[jira] [Created] (FLINK-16464) result-mode tableau may shift when content contains Chinese String in SQL CLI

Leonard Xu created FLINK-16464: -- Summary: result-mode tableau may shift when content contains Chinese String in SQL CLI Key: FLINK-16464 URL: https://issues.apache.org/jira/browse/FLINK-16464 Project

[jira] [Created] (FLINK-16405) Add hive-metastore dependency in connecting to hive docs

Leonard Xu created FLINK-16405: -- Summary: Add hive-metastore dependency in connecting to hive docs Key: FLINK-16405 URL: https://issues.apache.org/jira/browse/FLINK-16405 Project: Flink Issue

Re: [VOTE] FLIP-93: JDBC catalog and Postgres catalog

+1 (non-binding). Very useful feature especially for ETL, It will make connecting to existed DB systems easier. Best, Leonard > 在 2020年3月2日，21:58，Jark Wu 写道： > > +1 from my side. > > Best, > Jark > > On Mon, 2 Mar 2020 at 21:40, Kurt Young wrote: > >> +1 >> >> Best, >> Kurt >> >> >>

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

Hi Dawid， Thanks for driving this FLIP，big +1 for the proposal feature. About the connector.properties part, I suggest avoid using timestamp because timestamp is a keyword in DDL as dataType, user may feel confused, using 'timestamp.filed’ or ’source.timestamp’ will be better? ``` CREATE TABLE

[jira] [Created] (FLINK-16345) Computed column can not refer time attribute column

Leonard Xu created FLINK-16345: -- Summary: Computed column can not refer time attribute column Key: FLINK-16345 URL: https://issues.apache.org/jira/browse/FLINK-16345 Project: Flink Issue Type

[jira] [Created] (FLINK-16294) JDBC connector support create database table automatically

Leonard Xu created FLINK-16294: -- Summary: JDBC connector support create database table automatically Key: FLINK-16294 URL: https://issues.apache.org/jira/browse/FLINK-16294 Project: Flink Issue

[jira] [Created] (FLINK-16281) parameters 'maxRetryTimes' can not work in JDBCUpsertTableSink

Leonard Xu created FLINK-16281: -- Summary: parameters 'maxRetryTimes' can not work in JDBCUpsertTableSink Key: FLINK-16281 URL: https://issues.apache.org/jira/browse/FLINK-16281 Proj

Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer

Congratulations！！ Jingsong. Best, Leonard Xu > 在 2020年2月21日，11:18，tison 写道： > > Congrats Jingsong, well deserved! > > Best, > tison. > > > Xintong Song mailto:tonysong...@gmail.com>> > 于2020年2月21日周五 上午11:09写道： > Congratulations, Jingsong. Well de

[jira] [Created] (FLINK-16175) Add configOption to set CaseSensitive for SQL

Leonard Xu created FLINK-16175: -- Summary: Add configOption to set CaseSensitive for SQL Key: FLINK-16175 URL: https://issues.apache.org/jira/browse/FLINK-16175 Project: Flink Issue Type

[jira] [Created] (FLINK-16070) Blink planner can not extract correct unique key for UpsertStreamTableSink

Leonard Xu created FLINK-16070: -- Summary: Blink planner can not extract correct unique key for UpsertStreamTableSink Key: FLINK-16070 URL: https://issues.apache.org/jira/browse/FLINK-16070 Project

[jira] [Created] (FLINK-16048) Support read avro data that serialized by KafkaAvroSerializer from Kafka in Table

Leonard Xu created FLINK-16048: -- Summary: Support read avro data that serialized by KafkaAvroSerializer from Kafka in Table Key: FLINK-16048 URL: https://issues.apache.org/jira/browse/FLINK-16048

Re: [ANNOUNCE] Apache Flink 1.10.0 released

Great news！ Thanks everyone involved ! Thanks Gary and Yu for being the release manager ! Best, Leonard Xu > 在 2020年2月12日，23:02，Stephan Ewen 写道： > > Congrats to us all. > > A big piece of work, nicely done. > > Let's hope that this helps our users make their exi

[DISCUSS] What parts of Flink SQL should we improve for usability?

SQL do you think is still lacked according to your development experiences ? 4. Which aspects of Flink SQL's Usability do you think are not good enough ? 5. Any other suggestions or complaints to Flink SQL ? Any feedback is welcome. Best, Leonard Xu

Re: [VOTE] Improve TableFactory to add Context

+1(non-binding), nice design! after read full discussion mail list. Best, Leonard Xu > 在 2020年2月6日，23:12，Timo Walther 写道： > > +1 > > On 06.02.20 05:54, Bowen Li wrote: >> +1, LGTM >> On Tue, Feb 4, 2020 at 11:28 PM Jark Wu wrote: >>> +1 form

Re: [ANNOUNCE] Yu Li became a Flink committer

Congratulations!! Best, Leonard Xu > 在 2020年1月24日，21:17，张光辉 写道： > > Congratulations!!! > > Guowei Ma 于2020年1月24日周五 下午7:30写道： > >> Congratulations >> Best, >> Guowei >> >> >> 刘建刚 于2020年1月24日周五 下午5:56写道： >> >>> Congrat

Re: [ANNOUNCE] Dian Fu becomes a Flink committer

Congratulations! Dian Fu Best, Leonard > 在 2020年1月16日，18:00，Jeff Zhang 写道： > > Congrats Dian Fu ！ > > jincheng sun mailto:sunjincheng...@gmail.com>> > 于2020年1月16日周四 下午5:58写道： > Hi everyone, > > I'm very happy to announce that Dian accepted the offer of the Flink PMC to > become a committer

[jira] [Created] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

Leonard Xu created FLINK-15551: -- Summary: Streaming File Sink s3 end-to-end test FAIL Key: FLINK-15551 URL: https://issues.apache.org/jira/browse/FLINK-15551 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15508) support DataType with precision in ExpressionParser

Leonard Xu created FLINK-15508: -- Summary: support DataType with precision in ExpressionParser Key: FLINK-15508 URL: https://issues.apache.org/jira/browse/FLINK-15508 Project: Flink Issue Type

[jira] [Created] (FLINK-15485) Reopen tests like 'ignore TODO/when FLINK-xx is closed/when FLINK-xx is merged' has been finished

Leonard Xu created FLINK-15485: -- Summary: Reopen tests like 'ignore TODO/when FLINK-xx is closed/when FLINK-xx is merged' has been finished Key: FLINK-15485 URL: https://issues.apache.org/jira/browse/F

Re: [DISCUSS] Set default planner for SQL Client to Blink planner in 1.10 release

+1 for this. We bring many SQL/API features and enhance stability in 1.10 release, and almost all of them happens in Blink planner. SQL CLI is the most convenient entrypoint for me, I believe many users will have a better experience If we set Blink planner as default planner. Best, Leonard > 在

[jira] [Created] (FLINK-15461) Add Stream SQL end2end test to cover connecting to external systems

Leonard Xu created FLINK-15461: -- Summary: Add Stream SQL end2end test to cover connecting to external systems Key: FLINK-15461 URL: https://issues.apache.org/jira/browse/FLINK-15461 Project: Flink

[jira] [Created] (FLINK-15425) update outdated document of Connect to External Systems

Leonard Xu created FLINK-15425: -- Summary: update outdated document of Connect to External Systems Key: FLINK-15425 URL: https://issues.apache.org/jira/browse/FLINK-15425 Project: Flink Issue

[jira] [Created] (FLINK-15383) StreamExecSink should use sink Schema field name rather than query Schema field name

Leonard Xu created FLINK-15383: -- Summary: StreamExecSink should use sink Schema field name rather than query Schema field name Key: FLINK-15383 URL: https://issues.apache.org/jira/browse/FLINK-15383

[jira] [Created] (FLINK-15379) JDBC connector return wrong value if defined dataType contains precision

Leonard Xu created FLINK-15379: -- Summary: JDBC connector return wrong value if defined dataType contains precision Key: FLINK-15379 URL: https://issues.apache.org/jira/browse/FLINK-15379 Project: Flink

[jira] [Created] (FLINK-15366) Dimension table do not support computed column

Leonard Xu created FLINK-15366: -- Summary: Dimension table do not support computed column Key: FLINK-15366 URL: https://issues.apache.org/jira/browse/FLINK-15366 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15363) Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4)

Leonard Xu created FLINK-15363: -- Summary: Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4) Key: FLINK-15363 URL: https://issues.apache.org/jira/browse/FLINK-15363

[jira] [Created] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns

Leonard Xu created FLINK-15334: -- Summary: Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns Key: FLINK-15334 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

Leonard Xu created FLINK-15333: -- Summary: Using FlinkCostFactory rather than RelOptCostImpl in blink planner Key: FLINK-15333 URL: https://issues.apache.org/jira/browse/FLINK-15333 Project: Flink

Re: NPE in blink planner code gen

Hi, Benchao, thank you for your report. It looks egacy planner and blink planner have different behavior. Could you create an issue in https://issues.apache.org/jira/browse/FLINK ? > On Dec 15, 2019, at 16:17, Benchao Li wrote: > > hi all, > > W

Re: [ANNOUNCE] Zhu Zhu becomes a Flink committer

Congratulations, Zhu Zhu ! ! Best, Leonard Xu > On Dec 16, 2019, at 07:53, Becket Qin wrote: > > Congrats, Zhu Zhu! > > On Sun, Dec 15, 2019 at 10:26 PM Dian Fu wrote: > >> Congrats Zhu Zhu! >> >>> 在 2019年12月15日，下午6:23，Zhu Zhu 写道： >>> >&

[jira] [Created] (FLINK-15250) Docs of Table Connect to External Systems is outdate and need to fix

Leonard Xu created FLINK-15250: -- Summary: Docs of Table Connect to External Systems is outdate and need to fix Key: FLINK-15250 URL: https://issues.apache.org/jira/browse/FLINK-15250 Project: Flink

[jira] [Created] (FLINK-15200) legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil

Leonard Xu created FLINK-15200: -- Summary: legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil Key: FLINK-15200 URL: https://issues.apache.org/jira/browse/FLINK-15200

Re: [DISCUSS] Migrate build infrastructure from Travis CI to Azure Pipelines

will take about 25 minutes. @robert @chesnay Should we consider to compile once for multi cron task which have same profile in the new Azure Pipelines？ Best, Leonard Xu > On Dec 9, 2019, at 11:57, Congxian Qiu wrote: > > +1 for migrating to Azure pipelines as this can have shorter b

[jira] [Created] (FLINK-14924) CsvTableSource can not config empty column as null

Leonard Xu created FLINK-14924: -- Summary: CsvTableSource can not config empty column as null Key: FLINK-14924 URL: https://issues.apache.org/jira/browse/FLINK-14924 Project: Flink Issue Type

[jira] [Created] (FLINK-14900) output contains null value when a is null where a <> 'String'

Leonard Xu created FLINK-14900: -- Summary: output contains null value when a is null where a <> 'String' Key: FLINK-14900 URL: https://issues.apache.org/jira/browse/FLINK-14900

[jira] [Created] (FLINK-14895) same rank in rollup row with group row that all group key are null

Leonard Xu created FLINK-14895: -- Summary: same rank in rollup row with group row that all group key are null Key: FLINK-14895 URL: https://issues.apache.org/jira/browse/FLINK-14895 Project: Flink

[jira] [Created] (FLINK-14886) Wrong result in scalar query using blink planner

Leonard Xu created FLINK-14886: -- Summary: Wrong result in scalar query using blink planner Key: FLINK-14886 URL: https://issues.apache.org/jira/browse/FLINK-14886 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14882) Wrong null order when change flink default null order from NullCollation.LOW to NullCollation.FIRST

Leonard Xu created FLINK-14882: -- Summary: Wrong null order when change flink default null order from NullCollation.LOW to NullCollation.FIRST Key: FLINK-14882 URL: https://issues.apache.org/jira/browse/FLINK-14882

[jira] [Created] (FLINK-14861) parallelism.default in flink-conf.yaml do not work which is a bug imported by[FLINK-14745]

Leonard Xu created FLINK-14861: -- Summary: parallelism.default in flink-conf.yaml do not work which is a bug imported by[FLINK-14745] Key: FLINK-14861 URL: https://issues.apache.org/jira/browse/FLINK-14861

[jira] [Created] (FLINK-14784) CsvTableSink miss delimiter when row start with null member

Leonard Xu created FLINK-14784: -- Summary: CsvTableSink miss delimiter when row start with null member Key: FLINK-14784 URL: https://issues.apache.org/jira/browse/FLINK-14784 Project: Flink

Re: [ANNOUNCE] Jark Wu is now part of the Flink PMC

Congratulations, Jark. Thanks for your contribution and help. Best, Leonard Xu > On 2019年11月8日, at 下午6:37, Yun Gao wrote: > > Congratulations Jark！ > > Best, > Yun > > > -- > From:wenlong.lwl >

[jira] [Created] (FLINK-14677) validate all tpc-ds query result with TPC Official reference answer set

Leonard Xu created FLINK-14677: -- Summary: validate all tpc-ds query result with TPC Official reference answer set Key: FLINK-14677 URL: https://issues.apache.org/jira/browse/FLINK-14677 Project: Flink

[jira] [Created] (FLINK-14675) output directory settings of tpc-ds dataGenerator have length limitation

Leonard Xu created FLINK-14675: -- Summary: output directory settings of tpc-ds dataGenerator have length limitation Key: FLINK-14675 URL: https://issues.apache.org/jira/browse/FLINK-14675 Project: Flink

[jira] [Created] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

Leonard Xu created FLINK-14674: -- Summary: some tpc-ds query hang in scheduled stage for long time Key: FLINK-14674 URL: https://issues.apache.org/jira/browse/FLINK-14674 Project: Flink Issue

[jira] [Created] (FLINK-14625) Eliminate cross join in multi join to reduce cost

Leonard Xu created FLINK-14625: -- Summary: Eliminate cross join in multi join to reduce cost Key: FLINK-14625 URL: https://issues.apache.org/jira/browse/FLINK-14625 Project: Flink Issue Type

Re: [ANNOUNCE] Becket Qin joins the Flink PMC

Congratulations! Becket. Best, Leonard Xu > On 2019年10月29日, at 上午11:00, Zhenghua Gao wrote: > > Congratulations, Becket! > > *Best Regards,* > *Zhenghua Gao* > > > On Tue, Oct 29, 2019 at 10:34 AM Yun Gao > wrote: > >> Cong

[jira] [Created] (FLINK-14549) Bring more detail by using logicalType rather than conversionClass in exception msg

Leonard Xu created FLINK-14549: -- Summary: Bring more detail by using logicalType rather than conversionClass in exception msg Key: FLINK-14549 URL: https://issues.apache.org/jira/browse/FLINK-14549

[jira] [Created] (FLINK-14455) Improve join reorder feature without table statistics

Leonard Xu created FLINK-14455: -- Summary: Improve join reorder feature without table statistics Key: FLINK-14455 URL: https://issues.apache.org/jira/browse/FLINK-14455 Project: Flink Issue Type

[jira] [Created] (FLINK-14426) Test and pass 103 tpcds tests

Leonard Xu created FLINK-14426: -- Summary: Test and pass 103 tpcds tests Key: FLINK-14426 URL: https://issues.apache.org/jira/browse/FLINK-14426 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14425) Pick necessary commits gently that tpc-ds tests need from flink-tpc-ds project

Leonard Xu created FLINK-14425: -- Summary: Pick necessary commits gently that tpc-ds tests need from flink-tpc-ds project Key: FLINK-14425 URL: https://issues.apache.org/jira/browse/FLINK-14425 Project

[jira] [Created] (FLINK-14424) Create tpc-ds end to end test

Leonard Xu created FLINK-14424: -- Summary: Create tpc-ds end to end test Key: FLINK-14424 URL: https://issues.apache.org/jira/browse/FLINK-14424 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14423) Import teradat.tpcds as test data generator (refer to hive)

Leonard Xu created FLINK-14423: -- Summary: Import teradat.tpcds as test data generator (refer to hive) Key: FLINK-14423 URL: https://issues.apache.org/jira/browse/FLINK-14423 Project: Flink

<    2   3   4   5   6   7   8   >