[jira] [Closed] (FLINK-15336) Support temporal table function outer joins

[ https://issues.apache.org/jira/browse/FLINK-15336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-15336. -- Resolution: Resolved Implemented in  FLINK-16824, temporal table join supported left outer join  >

[jira] [Updated] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

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

[jira] [Resolved] (FLINK-15395) No API for execute insert into statement

[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-15395. Resolution: Resolved After introduce `executeSql()`  in FLINK-16366, it supports both DDL and DML

[jira] [Comment Edited] (FLINK-15395) No API for execute insert into statement

[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335429#comment-17335429 ] Leonard Xu edited comment on FLINK-15395 at 4/29/21, 12:43 PM: --- After

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

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-15440. Fix Version/s: 1.13.0 Resolution: Fixed you can try this in SQL Client or your application

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

Leonard Xu created FLINK-22525: -- Summary: The zone id in exception message should be GMT+08:00 instead of GMT+8:00 Key: FLINK-22525 URL: https://issues.apache.org/jira/browse/FLINK-22525 Project: Flink

[jira] [Comment Edited] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335131#comment-17335131 ] Leonard Xu edited comment on FLINK-17826 at 4/29/21, 4:02 AM: -- Hi,

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335131#comment-17335131 ] Leonard Xu commented on FLINK-17826: Hi, [~f.pompermaier]  The concern about the custom query is

[jira] [Resolved] (FLINK-19879) Support "IF NOT EXISTS" in DDL for CREATE TABLE

[ https://issues.apache.org/jira/browse/FLINK-19879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-19879. Fix Version/s: 1.12.0 Resolution: Fixed > Support "IF NOT EXISTS" in DDL for CREATE TABLE

[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=17331864#comment-17331864 ] Leonard Xu commented on FLINK-22472: CC :[~lzljs3620320] > The real partition data produced time is

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

Leonard Xu created FLINK-22472: -- Summary: The real partition data produced time is behind meta(_SUCCESS) file produced Key: FLINK-22472 URL: https://issues.apache.org/jira/browse/FLINK-22472 Project:

[jira] [Comment Edited] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330877#comment-17330877 ] Leonard Xu edited comment on FLINK-22356 at 4/23/21, 3:52 PM: -- After

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330877#comment-17330877 ] Leonard Xu commented on FLINK-22356: After offline discussion with Timo and Jark,  we reach a

[jira] [Commented] (FLINK-22428) Translate timezone page to Chinese

[ https://issues.apache.org/jira/browse/FLINK-22428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330445#comment-17330445 ] Leonard Xu commented on FLINK-22428: Thanks [~hackergin] for taking this. > Translate timezone page

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

[ https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21713: --- Release Note: The value of time function CURRENT_TIMESTAMP and NOW() are corrected from UTC time

[jira] [Updated] (FLINK-20387) Support defining event time attribute on TIMESTAMP_LTZ column

[ https://issues.apache.org/jira/browse/FLINK-20387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20387: --- Release Note: Support defining event time attribute on TIMESTAMP_LTZ column, base on this, Flink

[jira] [Created] (FLINK-22428) Translate timezone page to Chinese

Leonard Xu created FLINK-22428: -- Summary: Translate timezone page to Chinese Key: FLINK-22428 URL: https://issues.apache.org/jira/browse/FLINK-22428 Project: Flink Issue Type: Task

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

[ https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21713: --- Summary: Correct function

[jira] [Updated] (FLINK-20387) Support defining event time attribute on TIMESTAMP_LTZ column

[ https://issues.apache.org/jira/browse/FLINK-20387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20387: --- Summary: Support defining event time attribute on TIMESTAMP_LTZ column (was: Support column of

[jira] [Resolved] (FLINK-21617) FLIP-162: Consistent Flink SQL time function behavior

[ https://issues.apache.org/jira/browse/FLINK-21617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-21617. Fix Version/s: 1.13.0 Resolution: Implemented > FLIP-162: Consistent Flink SQL time

[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: --- Parent: (was: FLINK-21617) Issue Type: Improvement (was: Sub-task) >  Support higher

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

[ https://issues.apache.org/jira/browse/FLINK-21820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330023#comment-17330023 ] Leonard Xu commented on FLINK-21820: I think this issue should be valuable to improve > JDBC

[jira] [Comment Edited] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329272#comment-17329272 ] Leonard Xu edited comment on FLINK-22356 at 4/22/21, 4:48 PM: -- I think what

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329272#comment-17329272 ] Leonard Xu commented on FLINK-22356: I think What we want to achieve is that if users' data source

[jira] [Comment Edited] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17328471#comment-17328471 ] Leonard Xu edited comment on FLINK-22356 at 4/22/21, 12:48 PM: --- I found

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17328471#comment-17328471 ] Leonard Xu commented on FLINK-22356: I found two bad cases :( after rethink our proposal,  1. the

[jira] [Comment Edited] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327202#comment-17327202 ] Leonard Xu edited comment on FLINK-22356 at 4/22/21, 9:41 AM: -- Thanks 

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327202#comment-17327202 ] Leonard Xu commented on FLINK-22356: Thanks [~jark] and [~twalthr] ,  but maybe rowtime index is not

[jira] [Closed] (FLINK-16824) FLIP-132 Temporal Table DDL and Temporal Table Join

[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-16824. -- Fix Version/s: 1.12.0 Resolution: Resolved > FLIP-132 Temporal Table DDL and 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: --- Parent: (was: FLINK-16824) Issue Type: Improvement (was: Sub-task) > Properly

[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[ https://issues.apache.org/jira/browse/FLINK-19881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19881: --- Parent: (was: FLINK-16824) Issue Type: Improvement (was: Sub-task) > Optimize temporal

[jira] [Commented] (FLINK-16824) FLIP-132 Temporal Table DDL and Temporal Table Join

[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327084#comment-17327084 ] Leonard Xu commented on FLINK-16824: Yes, I'll close this. Thanks [~knaufk] > FLIP-132 Temporal

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326572#comment-17326572 ] Leonard Xu commented on FLINK-22356: I create an initial PR based on above comment, I'll add tests

[jira] [Commented] (FLINK-22356) Filesystem/Hive partition file is not committed when watermark is applied on rowtime of TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-22356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326561#comment-17326561 ] Leonard Xu commented on FLINK-22356: The root cause of this issue is the the extracted partition

[jira] [Commented] (FLINK-22122) StreamingKafkaITCase Fail due to TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326208#comment-17326208 ] Leonard Xu commented on FLINK-22122:

[jira] [Commented] (FLINK-22378) Type mismatch when declaring SOURCE_WATERMARK on TIMESTAMP_LTZ column

[ https://issues.apache.org/jira/browse/FLINK-22378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325909#comment-17325909 ] Leonard Xu commented on FLINK-22378: I think the return type of SOURCE_WATERMARK() should keep same

[jira] [Commented] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-22354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325900#comment-17325900 ] Leonard Xu commented on FLINK-22354: Thanks [~twalthr] , I'll open the PR to fix current behavior

[jira] [Comment Edited] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-22354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325835#comment-17325835 ] Leonard Xu edited comment on FLINK-22354 at 4/20/21, 2:31 PM: -- I used the

[jira] [Commented] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-22354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325835#comment-17325835 ] Leonard Xu commented on FLINK-22354: I used the new function stack and its very useful to add some

[jira] [Comment Edited] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-22354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325819#comment-17325819 ] Leonard Xu edited comment on FLINK-22354 at 4/20/21, 2:09 PM: -- [~twalthr] 

[jira] [Commented] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-22354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325819#comment-17325819 ] Leonard Xu commented on FLINK-22354: [~twalthr] MySQL is 0, Oracle and postgresql is 6, Snowflake is

[jira] [Closed] (FLINK-22374) ConfigOptionsDocsCompletenessITCase fails on traivs

[ https://issues.apache.org/jira/browse/FLINK-22374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-22374. -- Resolution: Invalid > ConfigOptionsDocsCompletenessITCase fails on traivs >

[jira] [Created] (FLINK-22374) ConfigOptionsDocsCompletenessITCase fails on traivs

Leonard Xu created FLINK-22374: -- Summary: ConfigOptionsDocsCompletenessITCase fails on traivs Key: FLINK-22374 URL: https://issues.apache.org/jira/browse/FLINK-22374 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22354) Failed to define watermark on computed column of CURRENT_TIMESTAMP and LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-22354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325753#comment-17325753 ] Leonard Xu commented on FLINK-22354: There're are some user feedback from the user mail list that

[jira] [Resolved] (FLINK-22160) Test Window TVF based aggregation and TopN

[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-22160. Resolution: Resolved > Test Window TVF based aggregation and TopN >

[jira] [Commented] (FLINK-22160) Test Window TVF based aggregation and TopN

[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325479#comment-17325479 ] Leonard Xu commented on FLINK-22160: * Tested TUMBLE/HOP/CUMULATE TVF in Sql-Client, the result is

[jira] [Commented] (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:comment-tabpanel=17323900#comment-17323900 ] Leonard Xu commented on FLINK-21716: I'll work for this. >  Support higher precision for Data Type

[jira] [Commented] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322760#comment-17322760 ] Leonard Xu commented on FLINK-21431: [~maguowei] I'll create a PR for 1.12 branch >

[jira] [Updated] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21431: --- Fix Version/s: 1.12.3 > UpsertKafkaTableITCase.testTemporalJoin hang >

[jira] [Updated] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20254: --- Description:

[jira] [Updated] (FLINK-22179) Manual test time function changes and new time attributes support

[ https://issues.apache.org/jira/browse/FLINK-22179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22179: --- Description: * 1. Test time functions return expected value in both batch and streaming mode, we

[jira] [Updated] (FLINK-22179) Manual test time function changes and new time attributes support

[ https://issues.apache.org/jira/browse/FLINK-22179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22179: --- Description: * 1. Test time functions return expected value in both batch and streaming mode, we

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321008#comment-17321008 ] Leonard Xu commented on FLINK-20254: {quote} Is this the same issue?

[jira] [Updated] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20254: --- Description:

[jira] [Updated] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20254: --- Description:

[jira] [Commented] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320094#comment-17320094 ] Leonard Xu commented on FLINK-21345: Hi [~zicat] Do you have time to update this PR? >

[jira] [Commented] (FLINK-22181) SourceNAryInputChainingITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319806#comment-17319806 ] Leonard Xu commented on FLINK-22181:

[jira] [Comment Edited] (FLINK-21516) UpsertKafkaTableITCase.testTemporalJoin fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-21516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319460#comment-17319460 ] Leonard Xu edited comment on FLINK-21516 at 4/12/21, 1:41 PM: -- Yes, the

[jira] [Resolved] (FLINK-21516) UpsertKafkaTableITCase.testTemporalJoin fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-21516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-21516. Resolution: Duplicate > UpsertKafkaTableITCase.testTemporalJoin fails on AZP >

[jira] [Commented] (FLINK-21516) UpsertKafkaTableITCase.testTemporalJoin fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-21516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319460#comment-17319460 ] Leonard Xu commented on FLINK-21516: Yes, the same root cause with FLINK-21431, I've raised a PR for 

[jira] [Updated] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18206: --- Priority: Critical (was: Blocker) > The timestamp is displayed incorrectly >

[jira] [Created] (FLINK-22179) Manual test time function changes and new time attributes support

Leonard Xu created FLINK-22179: -- Summary: Manual test time function changes and new time attributes support Key: FLINK-22179 URL: https://issues.apache.org/jira/browse/FLINK-22179 Project: Flink

[jira] [Created] (FLINK-22177) Add docs for consistent time functions and compatibility specification

Leonard Xu created FLINK-22177: -- Summary: Add docs for consistent time functions and compatibility specification Key: FLINK-22177 URL: https://issues.apache.org/jira/browse/FLINK-22177 Project: Flink

[jira] [Commented] (FLINK-21519) SQLClientHBaseITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317792#comment-17317792 ] Leonard Xu commented on FLINK-21519:  HBase has no official docker image and thus we can not use

[jira] [Commented] (FLINK-22122) StreamingKafkaITCase Fail due to TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317765#comment-17317765 ] Leonard Xu commented on FLINK-22122: another instance

[jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21345: --- Fix Version/s: 1.13.0 > NullPointerException >

[jira] [Comment Edited] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317637#comment-17317637 ] Leonard Xu edited comment on FLINK-18206 at 4/9/21, 4:14 AM: - we should

[jira] [Commented] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317637#comment-17317637 ] Leonard Xu commented on FLINK-18206: update the TIMESTAMP_LTZ display, the right display should be

[jira] [Updated] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18206: --- Attachment: image-2021-04-09-12-11-29-049.png > The timestamp is displayed incorrectly >

[jira] [Closed] (FLINK-20105) Temporal Table does not work when Kafka is used as the versioned side (planner PK problem)

[ https://issues.apache.org/jira/browse/FLINK-20105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-20105. -- Fix Version/s: (was: 1.13.0) Resolution: Not A Problem After discussion, this should not a

[jira] [Commented] (FLINK-22063) Lookup Join outputs wrong results for some scenario

[ https://issues.apache.org/jira/browse/FLINK-22063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316816#comment-17316816 ] Leonard Xu commented on FLINK-22063: Hi, [~icshuo] Do you have any progress? > Lookup Join outputs

[jira] [Closed] (FLINK-21557) An error was reported when temp join hive.

[ https://issues.apache.org/jira/browse/FLINK-21557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-21557. -- Resolution: Duplicate > An error was reported when temp join hive. >

[jira] [Closed] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type

[ https://issues.apache.org/jira/browse/FLINK-14036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-14036. -- Resolution: Won't Fix > function log(f0,f1) in Table API do not support decimal type >

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

[ https://issues.apache.org/jira/browse/FLINK-19074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19074. -- Resolution: Implemented > Materialize timeindicator in the right input of temporal join >

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

[ https://issues.apache.org/jira/browse/FLINK-19075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-19075. -- Resolution: Not A Problem > Infer changelog trait for temporal join node >

[jira] [Commented] (FLINK-22074) testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed

[ https://issues.apache.org/jira/browse/FLINK-22074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312513#comment-17312513 ] Leonard Xu commented on FLINK-22074: failed link

[jira] [Created] (FLINK-22074) testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed

Leonard Xu created FLINK-22074: -- Summary: testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed Key: FLINK-22074 URL:

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310391#comment-17310391 ] Leonard Xu commented on FLINK-22005: [~maguowei] Could you rebase to latest master, this issue has 

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

[ https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21713: --- Environment: * 1.The CURRENT_TIMESTAMP function returned timestamp of UTC+0 timezone with

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

[ https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21713: --- Release Note: Environment: * 1.The CURRENT_TIMESTAMP function returned timestamp of UTC+0

[jira] [Updated] (FLINK-21623) Introduce CURRENT_ROW_TIMESTAMP() function

[ https://issues.apache.org/jira/browse/FLINK-21623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21623: --- Summary: Introduce CURRENT_ROW_TIMESTAMP() function (was: Introduce CURRENT_ROW_TIMESTAMP

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

[ https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309467#comment-17309467 ] Leonard Xu commented on FLINK-21713: Okay, i'll write a note for this > Correct function >

[jira] [Comment Edited] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309437#comment-17309437 ] Leonard Xu edited comment on FLINK-21978 at 3/26/21, 1:49 PM: --  [~twalthr],

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309437#comment-17309437 ] Leonard Xu commented on FLINK-21978:  [~twalthr], Snowflake supports cast conversion between

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309326#comment-17309326 ] Leonard Xu commented on FLINK-21978: [~twalthr] Besides conversion class may cause confusion,

[jira] [Commented] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309189#comment-17309189 ] Leonard Xu commented on FLINK-19705: another instance

[jira] [Created] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

Leonard Xu created FLINK-21984: -- Summary: Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision) Key: FLINK-21984 URL: https://issues.apache.org/jira/browse/FLINK-21984

[jira] [Updated] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21978: --- Parent: FLINK-21617 Issue Type: Sub-task (was: Task) > Disable cast conversion between

[jira] [Created] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

Leonard Xu created FLINK-21978: -- Summary: Disable cast conversion between Numeric type and TIMESTAMP_LTZ type Key: FLINK-21978 URL: https://issues.apache.org/jira/browse/FLINK-21978 Project: Flink

[jira] [Updated] (FLINK-21715) Support implicit cast conversion between timestamp and timestamp_ltz

[ https://issues.apache.org/jira/browse/FLINK-21715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21715: --- Description: The existed UDFs using `LocalDateTime` or `java.sql.Timestamp` as parameters type, if

[jira] [Updated] (FLINK-21715) Support implicit cast conversion between timestamp and timestamp_ltz

[ https://issues.apache.org/jira/browse/FLINK-21715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21715: --- Description: The existed UDFs using `LocalDateTime` or `java.sql.Timestamp` as parameters type, if

[jira] [Updated] (FLINK-21715) Support implicit cast conversion between timestamp and timestamp_ltz

[ https://issues.apache.org/jira/browse/FLINK-21715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21715: --- Summary: Support implicit cast conversion between timestamp and timestamp_ltz (was: Introduce

[jira] [Created] (FLINK-21947) Support TIMESTAMP_LTZ type in CSV format

Leonard Xu created FLINK-21947: -- Summary: Support TIMESTAMP_LTZ type in CSV format Key: FLINK-21947 URL: https://issues.apache.org/jira/browse/FLINK-21947 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306915#comment-17306915 ] Leonard Xu commented on FLINK-20254: I think this is another bug in `collecting result` after some

[jira] [Updated] (FLINK-21917) Add back missing zh docs

[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21917: --- Description: We lost some Chinese doc pages when migrate  doc website from Jekyll to Hugo in

[jira] [Updated] (FLINK-21917) Add back missing zh docs

[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21917: --- Description: We lost some Chinese doc pages when migrate from legacy doc website to current one in

[jira] [Created] (FLINK-21917) Add back missing zh docs

Leonard Xu created FLINK-21917: -- Summary: Add back missing zh docs Key: FLINK-21917 URL: https://issues.apache.org/jira/browse/FLINK-21917 Project: Flink Issue Type: Bug Components:

[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=17304803#comment-17304803 ] Leonard Xu commented on FLINK-21871: Thanks [~jark] for driving this, the design looks well >

[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=17303059#comment-17303059 ] Leonard Xu commented on FLINK-21833: [~zicat] Thanks for the report, I'll help review this PR >

[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=17302620#comment-17302620 ] Leonard Xu commented on FLINK-21622: Thanks for you information [~twalthr], I'll consider the new

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