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

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

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

[ https://issues.apache.org/jira/browse/FLINK-21624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21624: --- Description: While using a simple query such as this   SELECT    `ts`,    FLOOR(`ts` TO WEEK) as `we

[jira] [Updated] (FLINK-20387) Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-20387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20387: --- Parent: FLINK-21617 Issue Type: Sub-task (was: New Feature) > Support column of TIMESTAMP W

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

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

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-21716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21716: --- Component/s: Table SQL / Runtime Table SQL / API >  Support higher precision for Da

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302620#comment-17302620 ] Leonard Xu commented on FLINK-21622: Thanks for you information [~twalthr], I'll con

[jira] [Commented] (FLINK-21833) TemporalRowTimeJoinOperator State Leak Although configure idle.state.retention.time

[ https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17303059#comment-17303059 ] Leonard Xu commented on FLINK-21833: [~zicat] Thanks for the report, I'll help revie

[jira] [Commented] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304803#comment-17304803 ] Leonard Xu commented on FLINK-21871: Thanks [~jark] for driving this, the design loo

[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-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&focusedCommentId=17361442#comment-17361442 ] Leonard Xu commented on FLINK-22970: minor: TO_TIMESTAMP doesn't use any time zone i

[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&focusedCommentId=17361442#comment-17361442 ] Leonard Xu edited comment on FLINK-22970 at 6/11/21, 6:22 AM:

[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&focusedCommentId=17365208#comment-17365208 ] Leonard Xu commented on FLINK-19830: [~junz] This feature depends on that Flink supp

[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&focusedCommentId=17366923#comment-17366923 ] Leonard Xu commented on FLINK-19830: [~twalthr] I checked that the old temporal func

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

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

[jira] [Closed] (FLINK-11020) Reorder joins only to eliminate cross joins

[ https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-11020. -- Resolution: Duplicate > Reorder joins only to eliminate cross joins > ---

[jira] [Closed] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-10999. -- Resolution: Not A Problem > Adding time multiple times causes Runtime : java.sql.Timestamp cannot be c

[jira] [Closed] (FLINK-10673) Table API / SQL UIDs not the only one

[ https://issues.apache.org/jira/browse/FLINK-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-10673. -- Resolution: Not A Problem > Table API / SQL UIDs not the only one > --

[jira] [Closed] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-10568. -- Resolution: Won't Fix The interface has been deprecated in FLINK-21081,  the new method  *Table.getRes

[jira] [Updated] (FLINK-10438) Built in functions should document the returned types

[ https://issues.apache.org/jira/browse/FLINK-10438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10438: --- Component/s: Documentation > Built in functions should document the returned types > ---

[jira] [Closed] (FLINK-8353) Add support for timezones

[ https://issues.apache.org/jira/browse/FLINK-8353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-8353. - Resolution: Fixed > Add support for timezones > - > > Key: FLINK-

[jira] [Resolved] (FLINK-10032) Rework SQL DATE_FORMAT function

[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10032. Resolution: Won't Fix > Rework SQL DATE_FORMAT function > --- > >

[jira] [Comment Edited] (FLINK-10032) Rework SQL DATE_FORMAT function

[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337035#comment-17337035 ] Leonard Xu edited comment on FLINK-10032 at 4/30/21, 2:48 AM:

[jira] [Commented] (FLINK-10032) Rework SQL DATE_FORMAT function

[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337035#comment-17337035 ] Leonard Xu commented on FLINK-10032: This bug is existed in legacy planner, the lega

[jira] [Comment Edited] (FLINK-10032) Rework SQL DATE_FORMAT function

[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337035#comment-17337035 ] Leonard Xu edited comment on FLINK-10032 at 4/30/21, 2:53 AM:

[jira] [Updated] (FLINK-10031) Support handling late events in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-10031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10031: --- Issue Type: Improvement (was: Bug) > Support handling late events in Table API & SQL >

[jira] [Updated] (FLINK-10031) Support handling late events in Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-10031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10031: --- Priority: Major (was: Minor) > Support handling late events in Table API & SQL > --

[jira] [Commented] (FLINK-10143) date_format throws CodeGenException

[ https://issues.apache.org/jira/browse/FLINK-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337037#comment-17337037 ] Leonard Xu commented on FLINK-10143: This bug exists in legacy planner, the legacy p

[jira] [Resolved] (FLINK-10017) Support keyed formats for Kafka table source sink factory

[ https://issues.apache.org/jira/browse/FLINK-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10017. Resolution: Implemented Implemented in FLINK-19294 > Support keyed formats for Kafka table source

[jira] [Updated] (FLINK-10014) Fix the decimal literal parameter problem for arithmetic functions in Table

[ https://issues.apache.org/jira/browse/FLINK-10014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10014: --- Component/s: (was: Table SQL / API) Table SQL / Runtime > Fix the decimal liter

[jira] [Updated] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class

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

[jira] [Updated] (FLINK-8535) Implement a basic set of table factories

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

[jira] [Updated] (FLINK-8566) Replace retract/insert of same record for state retention timer resets

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

[jira] [Updated] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

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

[jira] [Updated] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

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

[jira] [Closed] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL

[ https://issues.apache.org/jira/browse/FLINK-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-9161. - Resolution: Implemented you can use ROW which also supported nested type  {code:java} Flink SQL> SELECT C

[jira] [Commented] (FLINK-9484) Improve generic type inference for User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337049#comment-17337049 ] Leonard Xu commented on FLINK-9484: --- I found this improvement has been implemented in F

[jira] [Comment Edited] (FLINK-9484) Improve generic type inference for User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337049#comment-17337049 ] Leonard Xu edited comment on FLINK-9484 at 4/30/21, 3:52 AM: -

[jira] [Resolved] (FLINK-9484) Improve generic type inference for User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9484. --- Resolution: Duplicate > Improve generic type inference for User-Defined Functions > -

[jira] [Resolved] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9294. --- Resolution: Duplicate > Improve type inference for UDFs with composite parameter or result type > --

[jira] [Resolved] (FLINK-9501) Allow Object or Wildcard type in user-define functions as parameter types but not result types

[ https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9501. --- Resolution: Duplicate > Allow Object or Wildcard type in user-define functions as parameter types but

[jira] [Resolved] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type

[ https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9502. --- Resolution: Duplicate > Use generic parameter search for user-define functions when argument contains

[jira] [Resolved] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9327. --- Resolution: Implemented {code:java} Flink SQL> SELECT ROW(1,2); ++---

[jira] [Comment Edited] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337052#comment-17337052 ] Leonard Xu edited comment on FLINK-9327 at 4/30/21, 3:58 AM: -

[jira] [Updated] (FLINK-9422) Dedicated DISTINCT operator for streaming tables with time attributes

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

[jira] [Updated] (FLINK-9625) Enrich the error information to user

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

[jira] [Updated] (FLINK-9716) Support scans from table version function

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

[jira] [Updated] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Updated] (FLINK-9870) Support field mapping and time attributes for table sinks

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

[jira] [Resolved] (FLINK-10143) date_format throws CodeGenException

[ https://issues.apache.org/jira/browse/FLINK-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10143. Resolution: Won't Fix > date_format throws CodeGenException > ---

[jira] [Resolved] (FLINK-10049) Correctly handle NULL arguments in SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10049. Resolution: Implemented {noformat} Flink SQL> select abs(cast(null as int)); ++-+

[jira] [Updated] (FLINK-10210) Time indicators are not always materialised for LogicalCorrelate

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

[jira] [Updated] (FLINK-10211) Time indicators are not correctly materialized for LogicalJoin

[ https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10211: --- Component/s: (was: Table SQL / API) > Time indicators are not correctly materialized for Logical

[jira] [Resolved] (FLINK-10231) Add a view SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10231. Resolution: Implemented Has been supported in  FLINK-17105 > Add a view SQL DDL > ---

[jira] [Commented] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337060#comment-17337060 ] Leonard Xu commented on FLINK-10257: The bug still exists, cc [~lzljs3620320] {nofor

[jira] [Updated] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10257: --- Component/s: (was: Table SQL / API) Table SQL / Runtime > Incorrect CHAR type s

[jira] [Updated] (FLINK-10290) Conversion error in StreamScan and BatchScan

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

[jira] [Updated] (FLINK-10553) Unified sink and source table name in SQL statement

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

[jira] [Resolved] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10846. Resolution: Implemented > Add support for IS DISTINCT FROM in code generator > ---

[jira] [Commented] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337069#comment-17337069 ] Leonard Xu commented on FLINK-10846: {code:java} Flink SQL> select 1 IS DISTINCT FRO

[jira] [Resolved] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10847. Resolution: Implemented {noformat} Flink SQL> select 1 IS DISTINCT FROM 2; +++ | op |

[jira] [Comment Edited] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337070#comment-17337070 ] Leonard Xu edited comment on FLINK-10847 at 4/30/21, 4:39 AM:

[jira] [Closed] (FLINK-11242) The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-11242. -- Resolution: Not A Problem > The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI >

[jira] [Commented] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337124#comment-17337124 ] Leonard Xu commented on FLINK-10568: Thanks [~twalthr] for the explanation, I'm sorr

[jira] [Updated] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

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

[jira] [Updated] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

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

[jira] [Resolved] (FLINK-11399) Parsing nested ROW()s in SQL

[ https://issues.apache.org/jira/browse/FLINK-11399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-11399. Resolution: Implemented {noformat} Flink SQL> SELECT ROW(1,ROW(2, 3)); ++-

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

[ https://issues.apache.org/jira/browse/FLINK-22525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337156#comment-17337156 ] Leonard Xu commented on FLINK-22525: [~frank wang], we check the zone id is because

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

[ https://issues.apache.org/jira/browse/FLINK-22525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337156#comment-17337156 ] Leonard Xu edited comment on FLINK-22525 at 4/30/21, 7:50 AM:

[jira] [Updated] (FLINK-11543) Type mismatch AssertionError in FilterJoinRule

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

[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&focusedCommentId=17337193#comment-17337193 ] Leonard Xu commented on FLINK-11532: I close this now because `ExternalCatalogTable`

[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] [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&focusedCommentId=17337193#comment-17337193 ] Leonard Xu edited comment on FLINK-11532 at 4/30/21, 8:58 AM:

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

[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&focusedCommentId=17337198#comment-17337198 ] Leonard Xu commented on FLINK-12242: [~lirui] Could you take a look this ? > Suppor

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

[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&focusedCommentId=17337203#comment-17337203 ] Leonard Xu commented on FLINK-12243: [~lirui] Could you take a look this ? > Suppor

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

[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&focusedCommentId=17337207#comment-17337207 ] Leonard Xu commented on FLINK-12562: [~godfreyhe] Could you take over this one?  it'

[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&focusedCommentId=17337209#comment-17337209 ] Leonard Xu commented on FLINK-12710: [~twalthr] Could we close this one as its all s

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

[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 > kafkaTableSourceSinkFactoryBase.createS

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

[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&focusedCommentId=17337234#comment-17337234 ] Leonard Xu commented on FLINK-13580: Implemented in FLINK-15009 {code:java} @Funct

[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] [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 of

[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] [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&focusedCommentId=17337239#comment-17337239 ] Leonard Xu commented on FLINK-13773: [~lzljs3620320] Could you take a look these unf

[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, SequenceF

[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&focusedCommentId=17337244#comment-17337244 ] Leonard Xu commented on FLINK-14364: [~lirui] could you take a look this one? it's s

[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&focusedCommentId=17337246#comment-17337246 ] Leonard Xu commented on FLINK-15376: [~danny0405] Could you take a look this ticket?

[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  https://ci.apache.org/projects/flink/flin

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

[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&focusedCommentId=17341211#comment-17341211 ] Leonard Xu commented on FLINK-22559: The reason is the primary key indices is wrong

[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 > UpsertKafkaTableITCase.testKafk

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