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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421834#comment-17421834 ] Leonard Xu edited comment on FLINK-19830 at 9/29/21, 12:09 AM: --- Could you

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19830: --- Description: The exsiting TemporalProcessTimeJoinOperator has already supported temporal table

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19830: --- Description: The exsiting TemporalProcessTimeJoinOperator has already supported temporal table

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421830#comment-17421830 ] Leonard Xu commented on FLINK-19830: Hi [~gelimusong], the custom event mechanism did not start yet,

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19830: --- Fix Version/s: (was: 1.14.0) 1.15.0 > Properly implements processing-time

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418568#comment-17418568 ] Leonard Xu commented on FLINK-24168: [~qingru zhang] [~godfreyhe]  Should we also add documentation

[jira] [Updated] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24348: --- Issue Type: Bug (was: New Feature) > KafkaTableITCase fail with "ContainerLaunch Container startup

[jira] [Commented] (FLINK-24280) Support manual checkpoints triggering from a MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-24280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17414912#comment-17414912 ] Leonard Xu commented on FLINK-24280: Big +1 for this. > Support manual checkpoints triggering from

[jira] [Commented] (FLINK-23313) Reintroduce temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411906#comment-17411906 ] Leonard Xu commented on FLINK-23313: [~MartijnVisser] Sure, please assign this to me. > Reintroduce

[jira] [Comment Edited] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute ch

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1740#comment-1740 ] Leonard Xu edited comment on FLINK-24168 at 9/7/21, 10:26 AM: -- I think the

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1740#comment-1740 ] Leonard Xu commented on FLINK-24168: I think the the propagation is complex, but to check the input

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411080#comment-17411080 ] Leonard Xu commented on FLINK-24168: Thanks [~qingru zhang] for picking up this, *MATCH_ROWTIME()*

[jira] [Commented] (FLINK-24115) Outdated SQL Temporal Join Example

[ https://issues.apache.org/jira/browse/FLINK-24115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408259#comment-17408259 ] Leonard Xu commented on FLINK-24115: I fixed similar issue in

[jira] [Commented] (FLINK-24087) Kafka connector StartupMode requires a table dependency

[ https://issues.apache.org/jira/browse/FLINK-24087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407773#comment-17407773 ] Leonard Xu commented on FLINK-24087: [~airblader] It doesn't matter, I just found the issue and want

[jira] [Commented] (FLINK-24087) Kafka connector StartupMode requires a table dependency

[ https://issues.apache.org/jira/browse/FLINK-24087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407424#comment-17407424 ] Leonard Xu commented on FLINK-24087: nice catch! I'd like to help fix this one > Kafka connector

[jira] [Commented] (FLINK-24085) The `versioned table` and `Timezone` pages missed the first class subject

[ https://issues.apache.org/jira/browse/FLINK-24085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407335#comment-17407335 ] Leonard Xu commented on FLINK-24085: [~jark] Could you help assign this to me? appreciate if you can

[jira] [Created] (FLINK-24085) The `versioned table` and `Timezone` pages missed the first class subject

Leonard Xu created FLINK-24085: -- Summary: The `versioned table` and `Timezone` pages missed the first class subject Key: FLINK-24085 URL: https://issues.apache.org/jira/browse/FLINK-24085 Project:

[jira] [Commented] (FLINK-24084) The example in sql join document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-24084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407329#comment-17407329 ] Leonard Xu commented on FLINK-24084: CC [~sjwiesman] Could you help assign this one to me?

[jira] [Updated] (FLINK-24084) The example in sql join document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-24084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24084: --- Summary: The example in sql join document is incorrect (was: The example in sql join document

[jira] [Created] (FLINK-24084) The example in sql join document missed primary key

Leonard Xu created FLINK-24084: -- Summary: The example in sql join document missed primary key Key: FLINK-24084 URL: https://issues.apache.org/jira/browse/FLINK-24084 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407307#comment-17407307 ] Leonard Xu commented on FLINK-24081: [~dianfu] Could you help assign this to me? Appreciate if you

[jira] [Created] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

Leonard Xu created FLINK-24081: -- Summary: OVER window throws exception when the rowtime is timestamp_ltz type Key: FLINK-24081 URL: https://issues.apache.org/jira/browse/FLINK-24081 Project: Flink

[jira] [Closed] (FLINK-23819) Testing tgz file for python archives

[ https://issues.apache.org/jira/browse/FLINK-23819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-23819. -- Resolution: Resolved > Testing tgz file for python archives > >

[jira] [Comment Edited] (FLINK-23819) Testing tgz file for python archives

[ https://issues.apache.org/jira/browse/FLINK-23819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406376#comment-17406376 ] Leonard Xu edited comment on FLINK-23819 at 8/29/21, 8:40 AM: -- * Env: macOS

[jira] [Commented] (FLINK-23819) Testing tgz file for python archives

[ https://issues.apache.org/jira/browse/FLINK-23819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406376#comment-17406376 ] Leonard Xu commented on FLINK-23819: * Env: macOS * Python: 3.7 * Flink commit:

[jira] [Commented] (FLINK-23819) Testing tgz file for python archives

[ https://issues.apache.org/jira/browse/FLINK-23819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404953#comment-17404953 ] Leonard Xu commented on FLINK-23819: I'd like to take this one [~xtsong] > Testing tgz file for

[jira] [Closed] (FLINK-23945) 无法打开Flink dashboard界面

[ https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-23945. -- Resolution: Invalid [~zhongyangyang] please use English in Jira for all developers can understand

[jira] [Comment Edited] (FLINK-23675) flink1.13 cumulate 函数不能和部分比较函数连用

[ https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17395708#comment-17395708 ] Leonard Xu edited comment on FLINK-23675 at 8/9/21, 2:54 AM: - Please use

[jira] [Closed] (FLINK-23675) flink1.13 cumulate 函数不能和部分比较函数连用

[ https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-23675. -- Resolution: Invalid Please use English in issue, thanks > flink1.13 cumulate 函数不能和部分比较函数连用 >

[jira] [Created] (FLINK-23571) The internal query-start options missed when convert exec graph to transformation

Leonard Xu created FLINK-23571: -- Summary: The internal query-start options missed when convert exec graph to transformation Key: FLINK-23571 URL: https://issues.apache.org/jira/browse/FLINK-23571

[jira] [Commented] (FLINK-21302) Fix NPE when use row_number() in over agg

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388585#comment-17388585 ] Leonard Xu commented on FLINK-21302: +1 for cherry-pick to 1.12 > Fix NPE when use row_number() in

[jira] [Commented] (FLINK-23324) Postgres of JDBC Connector enable case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-23324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17381190#comment-17381190 ] Leonard Xu commented on FLINK-23324: Thanks [~ana4] for the detail report, it's a bug as we

[jira] [Commented] (FLINK-23313) Reintroduce temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17377347#comment-17377347 ] Leonard Xu commented on FLINK-23313: Thanks [~twalthr] for open this ticket, I keep the temporal

[jira] [Comment Edited] (FLINK-10734) Temporal joins on heavily filtered tables might fail in planning

[ https://issues.apache.org/jira/browse/FLINK-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375207#comment-17375207 ] Leonard Xu edited comment on FLINK-10734 at 7/6/21, 7:46 AM: - [~twalthr] 

[jira] [Commented] (FLINK-10734) Temporal joins on heavily filtered tables might fail in planning

[ https://issues.apache.org/jira/browse/FLINK-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375207#comment-17375207 ] Leonard Xu commented on FLINK-10734: [~twalthr] Although the bug still exits in legacy temporal join

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

[ https://issues.apache.org/jira/browse/FLINK-22764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22764: --- Description: The *Values Source* node may be produced in streaming sql plan optimization by

[jira] [Commented] (FLINK-23079) HiveTableSinkITCase fails

[ https://issues.apache.org/jira/browse/FLINK-23079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367054#comment-17367054 ] Leonard Xu commented on FLINK-23079: [~qingru zhang] Thanks for the report, but does this duplicate

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366923#comment-17366923 ] Leonard Xu commented on FLINK-19830: [~twalthr] I checked that the old temporal function work well,

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365208#comment-17365208 ] Leonard Xu commented on FLINK-19830: [~junz] This feature depends on that Flink supports custom

[jira] [Comment Edited] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361442#comment-17361442 ] Leonard Xu edited comment on FLINK-22970 at 6/11/21, 6:22 AM: -- [~tonywei]

[jira] [Commented] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361442#comment-17361442 ] Leonard Xu commented on FLINK-22970: minor: TO_TIMESTAMP doesn't use any time zone information. >

[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

[jira] [Commented] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356234#comment-17356234 ] Leonard Xu commented on FLINK-22861: I'll take this one > TIMESTAMPADD + timestamp_ltz type throws

[jira] [Updated] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22853: --- Summary: Flink SQL functions max/min/sum return duplicated records (was: FLinkSql functions

[jira] [Updated] (FLINK-22853) FLinkSql functions max/min/sum returns duplicated record

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22853: --- Summary: FLinkSql functions max/min/sum returns duplicated record (was:

[jira] [Updated] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22853: --- Priority: Major (was: Blocker) > FLinkSql聚合函数max/min/sum返回结果重复 > - > >

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354953#comment-17354953 ] Leonard Xu commented on FLINK-22826: [~sansejin] Thanks for the report, I think the root cause is

[jira] [Commented] (FLINK-22826) flink sql1.13.1基于change log流数据join导致数据丢失

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354947#comment-17354947 ] Leonard Xu commented on FLINK-22826: Please use English in Jira to make all devs/users can

[jira] [Closed] (FLINK-22826) flink sql1.13.1基于change log流数据join导致数据丢失

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-22826. -- Resolution: Invalid > flink sql1.13.1基于change log流数据join导致数据丢失 >

[jira] [Commented] (FLINK-22737) Add support for CURRENT_WATERMARK to SQL

[ https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354876#comment-17354876 ] Leonard Xu commented on FLINK-22737: * -1 for using *NULL* which will bring the three value logic

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17353118#comment-17353118 ] Leonard Xu commented on FLINK-20374: Thanks [~lzljs3620320] for taking this ticket, [~sansejin]  

[jira] [Commented] (FLINK-22795) Flink sql client -f option doesn't support load sql file from hdfs

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17353015#comment-17353015 ] Leonard Xu commented on FLINK-22795: Thanks [~mangguozhi] for report this. Currently both sql file

[jira] [Updated] (FLINK-22795) Flink sql client -f option doesn't support load sql file from hdfs

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22795: --- Description: hi, all When I executed following command in Flink 1.13 {code:java} bin/sql-client.sh

[jira] [Reopened] (FLINK-22795) Flink sql client -f option doesn't support load sql file from hdfs

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-22795: > Flink sql client -f option doesn't support load sql file from hdfs >

[jira] [Updated] (FLINK-22795) Flink sql client -f option doesn't support load sql file from hdfs

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22795: --- Description: hi, all When I executed following command in Flink 1.13 {code:java} bin/sql-client.sh

[jira] [Updated] (FLINK-22795) Flink sql client -f option doesn't support load sql file from hdfs

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22795: --- Description: hi, all When I executed following command in Flink 1.13 {code:java} bin/sql-client.sh

[jira] [Updated] (FLINK-22795) Flink sql client -f option doesn't support load sql file from hdfs

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22795: --- Summary: Flink sql client -f option doesn't support load sql file from hdfs (was: flink sql 1.13

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

[ https://issues.apache.org/jira/browse/FLINK-22764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352922#comment-17352922 ] Leonard Xu commented on FLINK-22764: I also know that FLIP-147 is final answer, this issue has

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

[ https://issues.apache.org/jira/browse/FLINK-22764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350837#comment-17350837 ] Leonard Xu commented on FLINK-22764: How about using option name

[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

[jira] [Updated] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21803: --- Fix Version/s: (was: 1.13.0) > Tumbling / Sliding windows are unaware of daylight savings time

[jira] [Comment Edited] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348019#comment-17348019 ] Leonard Xu edited comment on FLINK-21803 at 5/20/21, 2:34 AM: -- Since flink

[jira] [Reopened] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-21803: > Tumbling / Sliding windows are unaware of daylight savings time >

[jira] [Comment Edited] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348019#comment-17348019 ] Leonard Xu edited comment on FLINK-21803 at 5/20/21, 2:32 AM: -- Since flink

[jira] [Resolved] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-21803. Fix Version/s: 1.13.0 Resolution: Implemented Since flink 1.13 you can define time

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

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344273#comment-17344273 ] Leonard Xu commented on FLINK-22472: Yes, this may lead to your downstream tasks read empty data. 

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344232#comment-17344232 ] Leonard Xu commented on FLINK-15440: Hi [~Mathieu Druart] I didn't obtain information about 

[jira] [Commented] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343069#comment-17343069 ] Leonard Xu commented on FLINK-22637: I didn't find this fix commit

[jira] [Closed] (FLINK-22641) flink 1.13.0 文档 Concepts 下的 Timely Stream Processing 目录下有关waterMark描述

[ https://issues.apache.org/jira/browse/FLINK-22641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-22641. -- Resolution: Invalid Please use English in Jira for all users/devs can understand your report, feel

[jira] [Comment Edited] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342970#comment-17342970 ] Leonard Xu edited comment on FLINK-22637 at 5/12/21, 2:40 AM: -- Hi,

[jira] [Comment Edited] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342970#comment-17342970 ] Leonard Xu edited comment on FLINK-22637 at 5/12/21, 2:39 AM: -- Hi,

[jira] [Closed] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-22637. -- Resolution: Duplicate > UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed >

[jira] [Commented] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

[ https://issues.apache.org/jira/browse/FLINK-22637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342970#comment-17342970 ] Leonard Xu commented on FLINK-22637: Hi, [~mapohl]  This should be fixed in FLINK-22559, could you

[jira] [Closed] (FLINK-22629) table api sql ask

[ https://issues.apache.org/jira/browse/FLINK-22629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-22629. -- Resolution: Not A Problem Hi, [~LeoQq]  Jira issue means a bug, an improvement or a development

[jira] [Updated] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22559: --- Affects Version/s: (was: 1.13.0) 1.13.1 >

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341211#comment-17341211 ] Leonard Xu commented on FLINK-22559: The reason is the primary key indices is wrong which lead to

[jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22578: --- Fix Version/s: 1.13.1 1.14.0 > deployment configuration page miss content

[jira] [Resolved] (FLINK-9863) Add a built-in ingestion time TS extractor

[ https://issues.apache.org/jira/browse/FLINK-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9863. --- Resolution: Won't Fix The descriptor API is deprecated and will be refactored soon, it's recommend

[jira] [Resolved] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed

[ https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9278. --- Fix Version/s: 1.13.0 Resolution: Fixed See the doc 

[jira] [Commented] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337246#comment-17337246 ] Leonard Xu commented on FLINK-15376: [~danny0405] Could you take a look this ticket? > support

[jira] [Commented] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337244#comment-17337244 ] Leonard Xu commented on FLINK-14364: [~lirui] could you take a look this one? it's should be a csv

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14364: --- Component/s: (was: Table SQL / API) Formats (JSON, Avro, Parquet, ORC,

[jira] [Commented] (FLINK-13773) Rework of the Expression Design

[ https://issues.apache.org/jira/browse/FLINK-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337239#comment-17337239 ] Leonard Xu commented on FLINK-13773: [~lzljs3620320] Could you take a look these unfinished tasks?

[jira] [Updated] (FLINK-13580) Add overload support for user defined function to blink-planner

[ https://issues.apache.org/jira/browse/FLINK-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13580: --- Fix Version/s: 1.11.0 > Add overload support for user defined function to blink-planner >

[jira] [Resolved] (FLINK-13731) flink sql support window with alignment

[ https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-13731. Fix Version/s: 1.13.0 Resolution: Implemented Supported in FLINK-21714, the return value

[jira] [Commented] (FLINK-13580) Add overload support for user defined function to blink-planner

[ https://issues.apache.org/jira/browse/FLINK-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337234#comment-17337234 ] Leonard Xu commented on FLINK-13580: Implemented in FLINK-15009 {code:java} @FunctionHint(output =

[jira] [Resolved] (FLINK-13580) Add overload support for user defined function to blink-planner

[ https://issues.apache.org/jira/browse/FLINK-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-13580. Resolution: Implemented > Add overload support for user defined function to blink-planner >

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13052: --- Affects Version/s: (was: 1.8.0) > Supporting multi-topic when using >

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13052: --- Fix Version/s: 1.12.0 > Supporting multi-topic when using >

[jira] [Resolved] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-13052. Resolution: Implemented Implemented in FLINK-18449 > Supporting multi-topic when using >

[jira] [Commented] (FLINK-12710) Unify built-in and user-defined functions in the API modules

[ https://issues.apache.org/jira/browse/FLINK-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337209#comment-17337209 ] Leonard Xu commented on FLINK-12710: [~twalthr] Could we close this one as its all subtasks have

[jira] [Commented] (FLINK-12562) Improve code in ExpandColumnFunctionsRule

[ https://issues.apache.org/jira/browse/FLINK-12562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337207#comment-17337207 ] Leonard Xu commented on FLINK-12562: [~godfreyhe] Could you take over this one?  it's a code cleanup

[jira] [Updated] (FLINK-12562) Improve code in ExpandColumnFunctionsRule

[ https://issues.apache.org/jira/browse/FLINK-12562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-12562: --- Component/s: (was: Table SQL / API) Table SQL / Planner > Improve code in

[jira] [Commented] (FLINK-12243) Support generic table stats related operations in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337203#comment-17337203 ] Leonard Xu commented on FLINK-12243: [~lirui] Could you take a look this ? > Support generic table

[jira] [Updated] (FLINK-12243) Support generic table stats related operations in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-12243: --- Component/s: (was: Table SQL / API) Connectors / Hive > Support generic table

[jira] [Commented] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog

[ https://issues.apache.org/jira/browse/FLINK-12242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337198#comment-17337198 ] Leonard Xu commented on FLINK-12242: [~lirui] Could you take a look this ? > Support partition

[jira] [Updated] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog

[ https://issues.apache.org/jira/browse/FLINK-12242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-12242: --- Component/s: (was: Table SQL / API) Connectors / Hive > Support partition

[jira] [Comment Edited] (FLINK-11532) Remove the deprecation of ExternalCatalogTable.builder()

[ https://issues.apache.org/jira/browse/FLINK-11532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337193#comment-17337193 ] Leonard Xu edited comment on FLINK-11532 at 4/30/21, 8:58 AM: -- I close this

[jira] [Closed] (FLINK-11532) Remove the deprecation of ExternalCatalogTable.builder()

[ https://issues.apache.org/jira/browse/FLINK-11532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-11532. -- Resolution: Invalid > Remove the deprecation of ExternalCatalogTable.builder() >

[jira] [Commented] (FLINK-11532) Remove the deprecation of ExternalCatalogTable.builder()

[ https://issues.apache.org/jira/browse/FLINK-11532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337193#comment-17337193 ] Leonard Xu commented on FLINK-11532: I close this now because `ExternalCatalogTable` is removed in 

<    6   7   8   9   10   11   12   13   14   15   >