[jira] [Assigned] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

2022-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-20454: -- Assignee: li mo (was: CaoZhen) > Allow to read metadata for debezium-avro-confluent format

[jira] [Assigned] (FLINK-25289) Add DataStream sink test suite in connector testing framework

2022-02-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25289: -- Assignee: Hang Ruan > Add DataStream sink test suite in connector testing framework >

[jira] [Assigned] (FLINK-25840) Add semantic test support in the connector testframe

2022-02-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25840: -- Assignee: ruanhang1993 > Add semantic test support in the connector testframe >

[jira] [Assigned] (FLINK-25288) Add savepoint and metric cases in DataStream source suite of connector testing framework

2022-02-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25288: -- Assignee: ruanhang1993 > Add savepoint and metric cases in DataStream source suite of

[jira] [Updated] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils

2022-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-25712: --- Parent: FLINK-25286 Issue Type: Sub-task (was: Bug) > Merge flink-connector-testing into

[jira] [Resolved] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils

2022-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25712. Release Note: The flink-connector-testing module has been removed and should use

[jira] [Resolved] (FLINK-25287) Refactor connector testing framework interfaces

2022-01-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25287. Assignee: Qingsheng Ren Resolution: Fixed master: d864ce37da557e0709469803539c1ee16abf67b0

[jira] [Resolved] (FLINK-14100) Introduce OracleDialect

2022-01-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-14100. Fix Version/s: 1.15.0 Release Note: The Flink JDBC Connector supports Oracle Database.

[jira] [Updated] (FLINK-24758) filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

2022-01-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24758: --- Fix Version/s: 1.15.0 > filesystem sink: partition.time-extractor.kind support "MMdd" >

[jira] [Resolved] (FLINK-24758) filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

2022-01-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-24758. Resolution: Resolved master(1.15): c66720ae9fda223b9236aad0fa3b0eaf7a57831b > filesystem sink:

[jira] [Assigned] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

2021-12-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-21000: -- Assignee: Hang Ruan I assign this ticket to you [~ruanhang1993] , please keep discussion

[jira] [Closed] (FLINK-25264) Does the binlog_row_image of MySQL must be in full mode when Flink CDC is used?

2021-12-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-25264. -- Resolution: Invalid > Does the binlog_row_image of MySQL must be in full mode when Flink CDC is >

[jira] [Commented] (FLINK-25264) Does the binlog_row_image of MySQL must be in full mode when Flink CDC is used?

2021-12-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458544#comment-17458544 ] Leonard Xu commented on FLINK-25264: [~coco_yiyayiya] Yes, we need MySQL works under full mode for

[jira] [Closed] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-25 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-25048. -- Resolution: Invalid [~liangxinli] Please use English in Jira to make all developers can understand

[jira] [Resolved] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-24958. Resolution: Fixed > correct the example and link for temporal table function documentation >

[jira] [Updated] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24958: --- Fix Version/s: 1.14.1 > correct the example and link for temporal table function documentation >

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448356#comment-17448356 ] Leonard Xu commented on FLINK-24958: Fixed via master (1.15):

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-18 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446275#comment-17446275 ] Leonard Xu commented on FLINK-24958: Thanks [~zoucao] for report this, I assign this ticket to you

[jira] [Assigned] (FLINK-24958) correct the example and link for temporal table function documentation

2021-11-18 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-24958: -- Assignee: zoucao > correct the example and link for temporal table function documentation >

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

2021-11-15 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443924#comment-17443924 ] Leonard Xu commented on FLINK-19830: [~MartijnVisser]Yes, I'm work on this ticket. Do you any idea

[jira] [Updated] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

2021-11-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24855: --- Priority: Critical (was: Blocker) > Source Coordinator Thread already exists. There should never

[jira] [Commented] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

2021-11-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442072#comment-17442072 ] Leonard Xu commented on FLINK-24855: Thanks [~chesnay]  for looking into this. The related issue

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

2021-11-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440157#comment-17440157 ] Leonard Xu commented on FLINK-20374: [~lzljs3620320] Do you have plan to cp this fix to release-1.12

[jira] [Comment Edited] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438989#comment-17438989 ] Leonard Xu edited comment on FLINK-14527 at 11/5/21, 1:47 AM: --

[jira] [Commented] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438989#comment-17438989 ] Leonard Xu commented on FLINK-14527: [~MartijnVisser] I think we need this, we did cover this from

[jira] [Commented] (FLINK-24253) Load JdbcDialects via Service Loaders

2021-11-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438127#comment-17438127 ] Leonard Xu commented on FLINK-24253: Thanks [~sjwiesman] for the great work > Load JdbcDialects via

[jira] [Updated] (FLINK-24745) Add support for Oracle OGG json parser in flink-json module

2021-11-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24745: --- Priority: Major (was: Minor) > Add support for Oracle OGG json parser in flink-json module >

[jira] [Commented] (FLINK-24745) Add support for Oracle OGG json parser in flink-json module

2021-11-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437989#comment-17437989 ] Leonard Xu commented on FLINK-24745: Nice feature, I'll help review this PR > Add support for

[jira] [Commented] (FLINK-24511) "sink.parallelism" doesn't work for upsert "values" sink

2021-10-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427510#comment-17427510 ] Leonard Xu commented on FLINK-24511: I'd like to fix this, please assign to me [~jark] >

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

2021-09-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421834#comment-17421834 ] Leonard Xu commented on FLINK-19830: Could you [~jark] [~twalthr]  help add Jira assignment

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

2021-09-28 Thread Leonard Xu (Jira)
[ 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

2021-09-28 Thread Leonard Xu (Jira)
[ 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

2021-09-28 Thread Leonard Xu (Jira)
[ 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

2021-09-28 Thread Leonard Xu (Jira)
[ 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

2021-09-28 Thread Leonard Xu (Jira)
[ 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

2021-09-22 Thread Leonard Xu (Jira)
[ 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"

2021-09-21 Thread Leonard Xu (Jira)
[ 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

2021-09-14 Thread Leonard Xu (Jira)
[ 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

2021-09-08 Thread Leonard Xu (Jira)
[ 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

2021-09-07 Thread Leonard Xu (Jira)
[ 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

2021-09-07 Thread Leonard Xu (Jira)
[ 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

2021-09-07 Thread Leonard Xu (Jira)
[ 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

2021-09-01 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
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

2021-08-31 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
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

2021-08-31 Thread Leonard Xu (Jira)
[ 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

2021-08-31 Thread Leonard Xu (Jira)
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

2021-08-29 Thread Leonard Xu (Jira)
[ 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

2021-08-29 Thread Leonard Xu (Jira)
[ 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

2021-08-29 Thread Leonard Xu (Jira)
[ 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

2021-08-25 Thread Leonard Xu (Jira)
[ 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界面

2021-08-24 Thread Leonard Xu (Jira)
[ 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 函数不能和部分比较函数连用

2021-08-08 Thread Leonard Xu (Jira)
[ 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 函数不能和部分比较函数连用

2021-08-08 Thread Leonard Xu (Jira)
[ 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

2021-08-01 Thread Leonard Xu (Jira)
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

2021-07-28 Thread Leonard Xu (Jira)
[ 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.

2021-07-15 Thread Leonard Xu (Jira)
[ 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

2021-07-08 Thread Leonard Xu (Jira)
[ 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

2021-07-06 Thread Leonard Xu (Jira)
[ 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

2021-07-05 Thread Leonard Xu (Jira)
[ 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

2021-07-02 Thread Leonard Xu (Jira)
[ 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

2021-06-22 Thread Leonard Xu (Jira)
[ 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

2021-06-21 Thread Leonard Xu (Jira)
[ 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

2021-06-17 Thread Leonard Xu (Jira)
[ 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

2021-06-11 Thread Leonard Xu (Jira)
[ 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

2021-06-11 Thread Leonard Xu (Jira)
[ 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

2021-06-09 Thread Leonard Xu (Jira)
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

2021-06-03 Thread Leonard Xu (Jira)
[ 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

2021-06-02 Thread Leonard Xu (Jira)
[ 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

2021-06-02 Thread Leonard Xu (Jira)
[ 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返回结果重复

2021-06-02 Thread Leonard Xu (Jira)
[ 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

2021-06-01 Thread Leonard Xu (Jira)
[ 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导致数据丢失

2021-06-01 Thread Leonard Xu (Jira)
[ 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导致数据丢失

2021-06-01 Thread Leonard Xu (Jira)
[ 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

2021-06-01 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-28 Thread Leonard Xu (Jira)
[ 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

2021-05-27 Thread Leonard Xu (Jira)
[ 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

2021-05-25 Thread Leonard Xu (Jira)
[ 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

2021-05-25 Thread Leonard Xu (Jira)
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

2021-05-19 Thread Leonard Xu (Jira)
[ 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

2021-05-19 Thread Leonard Xu (Jira)
[ 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

2021-05-19 Thread Leonard Xu (Jira)
[ 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

2021-05-19 Thread Leonard Xu (Jira)
[ 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

2021-05-19 Thread Leonard Xu (Jira)
[ 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

2021-05-13 Thread Leonard Xu (Jira)
[ 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

2021-05-13 Thread Leonard Xu (Jira)
[ 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

2021-05-12 Thread Leonard Xu (Jira)
[ 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描述

2021-05-12 Thread Leonard Xu (Jira)
[ 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

2021-05-11 Thread Leonard Xu (Jira)
[ 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,

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