[jira] [Assigned] (FLINK-26739) Support Hive 2.3.8 and 2.3.9

[ https://issues.apache.org/jira/browse/FLINK-26739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-26739: -- Assignee: Cheng Pan > Support Hive 2.3.8 and 2.3.9 > > >

[jira] [Commented] (FLINK-26981) [Umbrella] Make Flink work on Apple M1 ARM chipset

[ https://issues.apache.org/jira/browse/FLINK-26981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515771#comment-17515771 ] Leonard Xu commented on FLINK-26981: Thanks [~martijnvisser] for openning this ticke

[jira] [Resolved] (FLINK-26928) Remove unnecessary Docker network creation in Kafka connector tests

[ https://issues.apache.org/jira/browse/FLINK-26928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26928. Resolution: Fixed > Remove unnecessary Docker network creation in Kafka connector tests >

[jira] [Comment Edited] (FLINK-26928) Remove unnecessary Docker network creation in Kafka connector tests

[ https://issues.apache.org/jira/browse/FLINK-26928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515139#comment-17515139 ] Leonard Xu edited comment on FLINK-26928 at 4/1/22 7:57 AM:

[jira] [Assigned] (FLINK-26927) Improve FlinkContainers to better support JM restarting

[ https://issues.apache.org/jira/browse/FLINK-26927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-26927: -- Assignee: Qingsheng Ren > Improve FlinkContainers to better support JM restarting > -

[jira] [Commented] (FLINK-26928) Remove unnecessary Docker network creation in Kafka connector tests

[ https://issues.apache.org/jira/browse/FLINK-26928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515139#comment-17515139 ] Leonard Xu commented on FLINK-26928: Fixed in master(1.16):47a1f32676b0920e287fed99

[jira] [Assigned] (FLINK-26928) Remove unnecessary Docker network creation in Kafka connector tests

[ https://issues.apache.org/jira/browse/FLINK-26928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-26928: -- Assignee: Qingsheng Ren > Remove unnecessary Docker network creation in Kafka connector tests

[jira] [Updated] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26422: --- Fix Version/s: 1.15.0 > Update Chinese documentation with the new TablePipeline docs > -

[jira] [Resolved] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26422. Resolution: Fixed > Update Chinese documentation with the new TablePipeline docs > ---

[jira] [Updated] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26422: --- Affects Version/s: 1.15.0 > Update Chinese documentation with the new TablePipeline docs > -

[jira] [Comment Edited] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509642#comment-17509642 ] Leonard Xu edited comment on FLINK-26422 at 3/22/22, 2:22 AM:

[jira] [Commented] (FLINK-26422) Update Chinese documentation with the new TablePipeline docs

[ https://issues.apache.org/jira/browse/FLINK-26422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509642#comment-17509642 ] Leonard Xu commented on FLINK-26422: Fixed in master(1.16) : 6ae234546bd33f14ee3fdb5

[jira] [Comment Edited] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509151#comment-17509151 ] Leonard Xu edited comment on FLINK-26618 at 3/20/22, 4:50 AM:

[jira] [Resolved] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26618. Resolution: Fixed > Remove jar statement not aligned with pipleline.jars > ---

[jira] [Commented] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509151#comment-17509151 ] Leonard Xu commented on FLINK-26618: Fixed: master(1.16):1b041dbd9a781ef7a3927df45

[jira] [Assigned] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-26618: -- Assignee: Paul Lin > Remove jar statement not aligned with pipleline.jars > -

[jira] [Created] (FLINK-26651) The connector CI build timeout in azure

Leonard Xu created FLINK-26651: -- Summary: The connector CI build timeout in azure Key: FLINK-26651 URL: https://issues.apache.org/jira/browse/FLINK-26651 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-26099) Table connector proctime attributes has syntax error

[ https://issues.apache.org/jira/browse/FLINK-26099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26099: --- Release Note: (was: Fixed in master(1.15): 38cfda517b7dfe42d3eaa2ecacdec64809e71e9f) > Table conn

[jira] [Commented] (FLINK-26099) Table connector proctime attributes has syntax error

[ https://issues.apache.org/jira/browse/FLINK-26099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503335#comment-17503335 ] Leonard Xu commented on FLINK-26099: Fixed in master(1.15): 38cfda517b7dfe42d3eaa2ec

[jira] [Resolved] (FLINK-26099) Table connector proctime attributes has syntax error

[ https://issues.apache.org/jira/browse/FLINK-26099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26099. Release Note: Fixed in master(1.15): 38cfda517b7dfe42d3eaa2ecacdec64809e71e9f Resolution: Fi

[jira] [Assigned] (FLINK-26099) Table connector proctime attributes has syntax error

[ https://issues.apache.org/jira/browse/FLINK-26099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-26099: -- Assignee: Mans Singh > Table connector proctime attributes has syntax error > ---

[jira] [Resolved] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26393. Assignee: Qingsheng Ren (was: Alexander Preuss) Resolution: Duplicate > KafkaITCase.testBro

[jira] [Resolved] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26387. Assignee: Qingsheng Ren (was: Alexander Preuss) Resolution: Fixed Fixed in master(1.15) : 5

[jira] [Updated] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-24407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24407: --- Fix Version/s: 1.14.4 (was: 1.14.3) > Pulsar connector chinese document link

[jira] [Resolved] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-24407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-24407. Fix Version/s: 1.15.0 Resolution: Fixed > Pulsar connector chinese document link to Pulsar

[jira] [Comment Edited] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-24407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494615#comment-17494615 ] Leonard Xu edited comment on FLINK-24407 at 2/23/22, 1:42 PM:

[jira] [Closed] (FLINK-26307) 当事件时间在（Long.MIN_VALUE ，-windowsize）时，不能正确的求到开启窗口的起始时间

[ https://issues.apache.org/jira/browse/FLINK-26307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-26307. -- Resolution: Invalid Please use English in JIRA, feel free to reopen after changing the description >

[jira] [Updated] (FLINK-26264) Python Test failed on its docs building phase

[ https://issues.apache.org/jira/browse/FLINK-26264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26264: --- Component/s: API / Python > Python Test failed on its docs building phase >

[jira] [Created] (FLINK-26264) Python Test failed on its docs building phase

Leonard Xu created FLINK-26264: -- Summary: Python Test failed on its docs building phase Key: FLINK-26264 URL: https://issues.apache.org/jira/browse/FLINK-26264 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-24407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494615#comment-17494615 ] Leonard Xu commented on FLINK-24407: master(1.15): 9f60c506366ae14405f0da487b3267aa3

[jira] [Created] (FLINK-26240) PulsarSinkITCase.tearDown failed in azure

Leonard Xu created FLINK-26240: -- Summary: PulsarSinkITCase.tearDown failed in azure Key: FLINK-26240 URL: https://issues.apache.org/jira/browse/FLINK-26240 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-26240) PulsarSinkITCase.tearDown failed in azure

[ https://issues.apache.org/jira/browse/FLINK-26240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26240: --- Component/s: Connectors / Pulsar > PulsarSinkITCase.tearDown failed in azure > -

[jira] [Created] (FLINK-26241) Pulsar.RoundRobinTopicRouterTest failed due to lang.ArithmeticException

Leonard Xu created FLINK-26241: -- Summary: Pulsar.RoundRobinTopicRouterTest failed due to lang.ArithmeticException Key: FLINK-26241 URL: https://issues.apache.org/jira/browse/FLINK-26241 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-24745. Fix Version/s: 1.15.0 Resolution: Implemented master(1.15): 894f41363541427df086c1f06d4825

[jira] [Resolved] (FLINK-25286) Improve connector testing framework to support more scenarios

[ https://issues.apache.org/jira/browse/FLINK-25286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25286. Assignee: Hang Ruan Resolution: Implemented Close the umbrella issue now as all subtasks hav

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

[ https://issues.apache.org/jira/browse/FLINK-25288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25288: -- Assignee: Hang Ruan (was: ruanhang1993) > Add savepoint and metric cases in DataStream sourc

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

[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25289. Fix Version/s: 1.15.0 Resolution: Resolved master(1.15) : 92de19c986fdefc11b4ee0515aac4d4f8

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

[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-24745: -- Assignee: luoyuxia (was: Steven) > Add support for Oracle OGG json parser in flink-json modu

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

[ https://issues.apache.org/jira/browse/FLINK-25840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25840: -- Assignee: Hang Ruan (was: ruanhang1993) > Add semantic test support in the connector testfra

[jira] [Assigned] (FLINK-25290) Add table source and sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25290: -- Assignee: Hang Ruan (was: ruanhang1993) > Add table source and sink test suite in connector

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-25288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25288. Resolution: Implemented Implemented in master(1.15) : 316f3086d7f29eeb638c9276d6b83a9784b70777 d

[jira] [Comment Edited] (FLINK-26126) Sink V2 will cause error numRecordsOut metric

[ https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492357#comment-17492357 ] Leonard Xu edited comment on FLINK-26126 at 2/15/22, 4:26 AM:

[jira] [Commented] (FLINK-26126) Sink V2 will cause error numRecordsOut metric

[ https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492357#comment-17492357 ] Leonard Xu commented on FLINK-26126: [~ruanhang1993] The blocker priority means we h

[jira] [Commented] (FLINK-25286) Improve connector testing framework to support more scenarios

[ https://issues.apache.org/jira/browse/FLINK-25286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491788#comment-17491788 ] Leonard Xu commented on FLINK-25286: I assigned these subtasks you raised PR to you

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

[ https://issues.apache.org/jira/browse/FLINK-25840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25840. Fix Version/s: 1.15.0 Resolution: Implemented master(1.15): f1e17c9f39b876537ae2065c6331baa

[jira] [Assigned] (FLINK-25290) Add table source and sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-25290: -- Assignee: ruanhang1993 > Add table source and sink test suite in connector testing framework

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-25264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458544#comment-17458544 ] Leonard Xu commented on FLINK-25264: [~coco_yiyayiya] Yes, we need MySQL works under

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446275#comment-17446275 ] Leonard Xu commented on FLINK-24958: Thanks [~zoucao] for report this, I assign this

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443924#comment-17443924 ] Leonard Xu commented on FLINK-19830: [~MartijnVisser]Yes, I'm work on this ticket. D

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442072#comment-17442072 ] Leonard Xu commented on FLINK-24855: Thanks [~chesnay]  for looking into this. The r

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

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440157#comment-17440157 ] Leonard Xu commented on FLINK-20374: [~lzljs3620320] Do you have plan to cp this fix

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438989#comment-17438989 ] Leonard Xu commented on FLINK-14527: [~MartijnVisser] I think we need this, we did c

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

[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438127#comment-17438127 ] Leonard Xu commented on FLINK-24253: Thanks [~sjwiesman] for the great work > Load

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437989#comment-17437989 ] Leonard Xu commented on FLINK-24745: Nice feature, I'll help review this PR > Add s

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

[ https://issues.apache.org/jira/browse/FLINK-24511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427510#comment-17427510 ] Leonard Xu commented on FLINK-24511: I'd like to fix this, please assign to me [~jar

[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=17421834#comment-17421834 ] Leonard Xu commented on FLINK-19830: Could you [~jark] [~twalthr]  help add Jira ass

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

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

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

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

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

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

[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=17421830#comment-17421830 ] Leonard Xu commented on FLINK-19830: Hi [~gelimusong], the custom event mechanism di

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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