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

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

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

[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

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

[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

[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

[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] [Created] (FLINK-21623) Introduce CURRENT_ROW_TIMESTAMP function

Leonard Xu created FLINK-21623: -- Summary: Introduce CURRENT_ROW_TIMESTAMP function Key: FLINK-21623 URL: https://issues.apache.org/jira/browse/FLINK-21623 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-21620) Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

[ https://issues.apache.org/jira/browse/FLINK-21620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21620: --- Summary: Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE (was:

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

Leonard Xu created FLINK-21622: -- Summary: Introduce function TO_TIMESTAMP_LTZ(numeric [, precision]) Key: FLINK-21622 URL: https://issues.apache.org/jira/browse/FLINK-21622 Project: Flink

[jira] [Created] (FLINK-21621) Support TIMESTAMP_LTZ arithmetic

Leonard Xu created FLINK-21621: -- Summary: Support TIMESTAMP_LTZ arithmetic Key: FLINK-21621 URL: https://issues.apache.org/jira/browse/FLINK-21621 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21620) [table-planner/table-parser] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

Leonard Xu created FLINK-21620: -- Summary: [table-planner/table-parser] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE Key: FLINK-21620 URL: https://issues.apache.org/jira/browse/FLINK-21620

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

Leonard Xu created FLINK-21617: -- Summary: FLIP-162: Consistent Flink SQL time function behavior Key: FLINK-21617 URL: https://issues.apache.org/jira/browse/FLINK-21617 Project: Flink Issue

[jira] [Commented] (FLINK-21523) ArrayIndexOutOfBoundsException occurs while run a hive streaming job with partitioned table source

[ https://issues.apache.org/jira/browse/FLINK-21523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295085#comment-17295085 ] Leonard Xu commented on FLINK-21523: Make sense to me > ArrayIndexOutOfBoundsException occurs while

[jira] [Created] (FLINK-21575) Replace InputFormat with BulkFormat in HivePartition Reader

Leonard Xu created FLINK-21575: -- Summary: Replace InputFormat with BulkFormat in HivePartition Reader Key: FLINK-21575 URL: https://issues.apache.org/jira/browse/FLINK-21575 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288925#comment-17288925 ] Leonard Xu commented on FLINK-21431:  I'll take a look [~dwysakowicz] >

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

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21302: --- Issue Type: Bug (was: New Feature) > Fix NPE when use row_number() in over agg >

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

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

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276043#comment-17276043 ] Leonard Xu commented on FLINK-21203: +1 for the ticket, [~wangpeibin] About the config option,

[jira] [Created] (FLINK-21183) Support watermark for Hive streaming source

Leonard Xu created FLINK-21183: -- Summary: Support watermark for Hive streaming source Key: FLINK-21183 URL: https://issues.apache.org/jira/browse/FLINK-21183 Project: Flink Issue Type:

[jira] [Closed] (FLINK-18903) Flink集成Hive内置时间函数使用报错

[ https://issues.apache.org/jira/browse/FLINK-18903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-18903. -- Resolution: Invalid Thanks for the report, but please use English in JIRA > Flink集成Hive内置时间函数使用报错 >

[jira] [Comment Edited] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273403#comment-17273403 ] Leonard Xu edited comment on FLINK-16799 at 1/28/21, 8:23 AM: -- [~zhangjun] 

[jira] [Closed] (FLINK-20771) Hive partition is not added when there is a lot of data

[ https://issues.apache.org/jira/browse/FLINK-20771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-20771. -- Resolution: Fixed > Hive partition is not added when there is a lot of data >

[jira] [Commented] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273403#comment-17273403 ] Leonard Xu commented on FLINK-16799: [~zhangjun] Any update of this PR? could you rebase you code. 

[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=17272210#comment-17272210 ] Leonard Xu commented on FLINK-20254: I dig up this and found it's a bug hidden in

[jira] [Commented] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271978#comment-17271978 ] Leonard Xu commented on FLINK-21013: I'd like to fix and back port to 1.11/1.12, please assign this

[jira] [Updated] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19436: --- Fix Version/s: 1.11.4 > TPC-DS end-to-end test (Blink planner) failed during shutdown >

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1727#comment-1727 ] Leonard Xu commented on FLINK-19436: Thanks for the report [~dwysakowicz] IIRC, we didn't pick the

[jira] [Comment Edited] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270555#comment-17270555 ] Leonard Xu edited comment on FLINK-21104 at 1/23/21, 5:20 AM: -- I think

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17270555#comment-17270555 ] Leonard Xu commented on FLINK-21104: I think these fail cases are caused by FLINK-29654 and commit

[jira] [Comment Edited] (FLINK-21032) JsonFileCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17268345#comment-17268345 ] Leonard Xu edited comment on FLINK-21032 at 1/20/21, 3:19 AM: --   >From the

[jira] [Commented] (FLINK-21032) JsonFileCompactionITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17268345#comment-17268345 ] Leonard Xu commented on FLINK-21032:   >From the detail log, the job has 3

[jira] [Commented] (FLINK-18726) Support INSERT INTO specific columns

[ https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267594#comment-17267594 ] Leonard Xu commented on FLINK-18726: Hello, [~atri] What's the progress of the project? This

[jira] [Commented] (FLINK-20812) Support 'properties.*' option to pass through all the HBase properties

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267068#comment-17267068 ] Leonard Xu commented on FLINK-20812: Thanks [~hxbks2ks] for the report,  the Hadoop `Configuration`

[jira] [Commented] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266954#comment-17266954 ] Leonard Xu commented on FLINK-21002: +1 to support this feature in Table/SQL  > Support exactly

[jira] [Commented] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed

[ https://issues.apache.org/jira/browse/FLINK-20500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265987#comment-17265987 ] Leonard Xu commented on FLINK-20500: I think we can reopen this ticket, CC: [~fsk119]  >

[jira] [Reopened] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed

[ https://issues.apache.org/jira/browse/FLINK-20500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-20500: > UpsertKafkaTableITCase.testTemporalJoin test failed >

[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'

[ https://issues.apache.org/jira/browse/FLINK-20979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20979: --- Labels: starter (was: ) > Wrong description of 'sink.bulk-flush.max-actions' >

[jira] [Created] (FLINK-20983) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 60000milliseconds while awaiting InitProducerId

Leonard Xu created FLINK-20983: -- Summary: FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce failed with Timeout expired after 6milliseconds while awaiting InitProducerId Key: FLINK-20983 URL:

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265620#comment-17265620 ] Leonard Xu commented on FLINK-20726: [~Jianyun Zhao] Happy to see the community has volunteer to

[jira] [Comment Edited] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

[ https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258216#comment-17258216 ] Leonard Xu edited comment on FLINK-20840 at 1/14/21, 8:33 AM: -- [~fsk119]

[jira] [Updated] (FLINK-20940) The LOCALTIME/LOCALTIMSTAMP functions should use session time zone

[ https://issues.apache.org/jira/browse/FLINK-20940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20940: --- Component/s: Table SQL / API > The LOCALTIME/LOCALTIMSTAMP functions should use session time zone

[jira] [Updated] (FLINK-20940) The LOCALTIME/LOCALTIMSTAMP functions should use session time zone

[ https://issues.apache.org/jira/browse/FLINK-20940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20940: --- Parent: FLINK-20162 Issue Type: Sub-task (was: Bug) > The LOCALTIME/LOCALTIMSTAMP

[jira] [Created] (FLINK-20940) The LOCALTIME/LOCALTIMSTAMP functions should use session time zone

Leonard Xu created FLINK-20940: -- Summary: The LOCALTIME/LOCALTIMSTAMP functions should use session time zone Key: FLINK-20940 URL: https://issues.apache.org/jira/browse/FLINK-20940 Project: Flink

[jira] [Commented] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263015#comment-17263015 ] Leonard Xu commented on FLINK-20909: I‘d like to review this PR ^^ [~qingru zhang] > MiniBatch

[jira] [Commented] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name

[ https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262211#comment-17262211 ] Leonard Xu commented on FLINK-20887: Hi, [~TsReaper] I think it's not related to the 

[jira] [Comment Edited] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

[ https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258216#comment-17258216 ] Leonard Xu edited comment on FLINK-20840 at 1/4/21, 1:52 PM: - [~fsk119] The

[jira] [Commented] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

[ https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258216#comment-17258216 ] Leonard Xu commented on FLINK-20840: The rule `FlinkProjectJoinTransposeRule` was added in logical

[jira] [Updated] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

[ https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20840: --- Description: {code:java} sql 1: |SELECT T.*, D.id |FROM MyTable AS T |JOIN LookupTable FOR

[jira] [Reopened] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

[ https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-20840: > Projection pushdown doesn't work in temporal(lookup) join >

[jira] [Closed] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

[ https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-20840. -- Resolution: Duplicate > Projection pushdown doesn't work in temporal(lookup) join >

[jira] [Created] (FLINK-20840) Projection pushdown doesn't work in temporal(lookup) join

Leonard Xu created FLINK-20840: -- Summary: Projection pushdown doesn't work in temporal(lookup) join Key: FLINK-20840 URL: https://issues.apache.org/jira/browse/FLINK-20840 Project: Flink Issue

[jira] [Updated] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19635: --- Fix Version/s: 1.13.0 > HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result

[jira] [Updated] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

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

[jira] [Updated] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

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

[jira] [Reopened] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-19635: > HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result > mismatch >

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256332#comment-17256332 ] Leonard Xu commented on FLINK-19635: oops, let me reopen this >

[jira] [Created] (FLINK-20746) Support ignore-first-line option for CSV format

Leonard Xu created FLINK-20746: -- Summary: Support ignore-first-line option for CSV format Key: FLINK-20746 URL: https://issues.apache.org/jira/browse/FLINK-20746 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253846#comment-17253846 ] Leonard Xu edited comment on FLINK-20726 at 12/23/20, 2:33 AM: --- Thanks

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253846#comment-17253846 ] Leonard Xu commented on FLINK-20726: Thanks [~Jianyun Zhao] and Pulsar community for bringing this

[jira] [Commented] (FLINK-20667) Configurable batch size for vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-20667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251474#comment-17251474 ] Leonard Xu commented on FLINK-20667: The question also reported in [stack

[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=17251471#comment-17251471 ] Leonard Xu commented on FLINK-20254: Thanks [~hxbks2ks] I'll look into this soon >

[jira] [Updated] (FLINK-20540) The baseurl for pg database is incorrect in JdbcCatalog page

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20540: --- Summary: The baseurl for pg database is incorrect in JdbcCatalog page (was: The baseurl for pg

[jira] [Updated] (FLINK-20540) The baseurl for pg database is incorrect in

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20540: --- Summary: The baseurl for pg database is incorrect in (was: Failed connecting to

[jira] [Updated] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20540: --- Component/s: Documentation > Failed connecting to

[jira] [Updated] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20540: --- Priority: Minor (was: Major) > Failed connecting to

[jira] [Updated] (FLINK-20570) The `NOTE` tip style is different from the others in process_function page.

[ https://issues.apache.org/jira/browse/FLINK-20570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20570: --- Component/s: API / DataStream > The `NOTE` tip style is different from the others in

[jira] [Updated] (FLINK-20570) The `NOTE` tip style is different from the others in process_function page.

[ https://issues.apache.org/jira/browse/FLINK-20570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20570: --- Summary: The `NOTE` tip style is different from the others in process_function page. (was:

[jira] [Commented] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247045#comment-17247045 ] Leonard Xu commented on FLINK-20540: Happy to hear you're willing to contribute, I think we can fix

[jira] [Updated] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20552: --- Summary: JdbcDynamicTableSink doesn't sink buffered data on checkpoint (was: Jdbc connector don't

[jira] [Commented] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247002#comment-17247002 ] Leonard Xu commented on FLINK-20552: Hi, [~meijies]  Thanks for the report， A simple way to fix

[jira] [Comment Edited] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246277#comment-17246277 ] Leonard Xu edited comment on FLINK-20540 at 12/9/20, 3:56 AM: -- [~kgzhang] 

[jira] [Commented] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246277#comment-17246277 ] Leonard Xu commented on FLINK-20540: [~kgzhang] Thanks for your report,  The default dabase name is

[jira] [Commented] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed

[ https://issues.apache.org/jira/browse/FLINK-20500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245643#comment-17245643 ] Leonard Xu commented on FLINK-20500: I'd like to look into this.  >

[jira] [Commented] (FLINK-20494) SQLClientHBaseITCase Task Timeout

[ https://issues.apache.org/jira/browse/FLINK-20494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244948#comment-17244948 ] Leonard Xu commented on FLINK-20494: Thanks for the report [~hxbks2ks] But the error log 

[jira] [Updated] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

[ https://issues.apache.org/jira/browse/FLINK-20502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20502: --- Attachment: flink-vsts-standalonesession-0-fv-az655-588.log > Reduce the uploading time of hadoop

[jira] [Created] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

Leonard Xu created FLINK-20502: -- Summary: Reduce the uploading time of hadoop jars in hbase e2e test Key: FLINK-20502 URL: https://issues.apache.org/jira/browse/FLINK-20502 Project: Flink

[jira] [Commented] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243952#comment-17243952 ] Leonard Xu commented on FLINK-20486: Thanks [~lirui] for the report, I agree that unlock the

[jira] [Created] (FLINK-20484) Improve hive temporal table exception

Leonard Xu created FLINK-20484: -- Summary: Improve hive temporal table exception Key: FLINK-20484 URL: https://issues.apache.org/jira/browse/FLINK-20484 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-20471) flink1.10SQL中decimal精度溢出返回null的问题

[ https://issues.apache.org/jira/browse/FLINK-20471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243216#comment-17243216 ] Leonard Xu edited comment on FLINK-20471 at 12/3/20, 2:30 PM: -- Hi,

[jira] [Commented] (FLINK-20471) flink1.10SQL中decimal精度溢出返回null的问题

[ https://issues.apache.org/jira/browse/FLINK-20471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243216#comment-17243216 ] Leonard Xu commented on FLINK-20471: Hi, [~sadf]  Thanks fro the report, please use English in

[jira] [Comment Edited] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242387#comment-17242387 ] Leonard Xu edited comment on FLINK-20452 at 12/2/20, 2:45 PM: -- Hi,

[jira] [Comment Edited] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242387#comment-17242387 ] Leonard Xu edited comment on FLINK-20452 at 12/2/20, 2:19 PM: -- Hi,

[jira] [Commented] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242387#comment-17242387 ] Leonard Xu commented on FLINK-20452: [~HideOnBush] Thanks for the report, but i think it's not a

[jira] [Commented] (FLINK-19398) Hive connector fails with IllegalAccessError if submitted as usercode

[ https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241647#comment-17241647 ] Leonard Xu commented on FLINK-19398: [~gaoyunhaii] Could you raise a PR for 1.11 branch and then we

[jira] [Commented] (FLINK-20341) Rework Deployment / Coordination Documentation

[ https://issues.apache.org/jira/browse/FLINK-20341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241579#comment-17241579 ] Leonard Xu commented on FLINK-20341: Hi, [~rmetzger] [~trohrmann] Kindly remind,  we'd better use

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241492#comment-17241492 ] Leonard Xu commented on FLINK-19863: I create a PR to fix this,

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241381#comment-17241381 ] Leonard Xu commented on FLINK-19863:  The test failed with timeout 30 seconds when run the `insert

[jira] [Commented] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241275#comment-17241275 ] Leonard Xu commented on FLINK-20377: [~hiscat] Is this not a problem?  > flink-1.11.2 -kerberos

[jira] [Resolved] (FLINK-19082) Add docs for temporal table and temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-19082. Fix Version/s: 1.13.0 Resolution: Resolved 1.12: 4d94a26afb11019be116c4ed15fb1f215382cc73

[jira] [Commented] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241231#comment-17241231 ] Leonard Xu commented on FLINK-20377: Thanks for the report, [~hiscat] [~becket_qin] Could you help

[jira] [Commented] (FLINK-20429) KafkaTableITCase.testKafkaTemporalJoinChangelog failed with unexpected results

[ https://issues.apache.org/jira/browse/FLINK-20429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241186#comment-17241186 ] Leonard Xu commented on FLINK-20429: Thanks [~dian.fu] for the report, Could you help assign this to

[jira] [Closed] (FLINK-20405) The LAG function in over window is not implemented correctly

[ https://issues.apache.org/jira/browse/FLINK-20405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-20405. -- Resolution: Duplicate > The LAG function in over window is not implemented correctly >

[jira] [Commented] (FLINK-20405) The LAG function in over window is not implemented correctly

[ https://issues.apache.org/jira/browse/FLINK-20405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17240468#comment-17240468 ] Leonard Xu commented on FLINK-20405: [~libenchao] You're wright,  I will close and link to the

[jira] [Created] (FLINK-20405) The LAG function in over window is not implements correctly

Leonard Xu created FLINK-20405: -- Summary: The LAG function in over window is not implements correctly Key: FLINK-20405 URL: https://issues.apache.org/jira/browse/FLINK-20405 Project: Flink

[jira] [Updated] (FLINK-20385) Allow to read metadata for Canal-json format

[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20385: --- Description: In FLIP-107, we support read meta from CDC format Debezium, Canal-json is also

[jira] [Created] (FLINK-20385) Allow to read metadata for Canal-json format

Leonard Xu created FLINK-20385: -- Summary: Allow to read metadata for Canal-json format Key: FLINK-20385 URL: https://issues.apache.org/jira/browse/FLINK-20385 Project: Flink Issue Type: New

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