[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17608051#comment-17608051 ] Leonard Xu commented on FLINK-6573: --- I've assigned this ticket to [~jiabao.sun] as he has start the

[jira] [Assigned] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-6573: - Assignee: Jiabao Sun (was: ZhuoYu Chen) > Flink MongoDB Connector > --- >

[jira] [Resolved] (FLINK-29087) Jdbc connector sql ITCase failed when run in idea

[ https://issues.apache.org/jira/browse/FLINK-29087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-29087. Resolution: Fixed Fixed in master(1.16): d55be6850dc2a4e0291c0a4853fa5aa7a51a1d10 > Jdbc

[jira] [Assigned] (FLINK-29087) Jdbc connector sql ITCase failed when run in idea

[ https://issues.apache.org/jira/browse/FLINK-29087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-29087: -- Assignee: xuyang > Jdbc connector sql ITCase failed when run in idea >

[jira] [Resolved] (FLINK-28783) Class ConfigOptions's example code have error.

[ https://issues.apache.org/jira/browse/FLINK-28783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-28783. Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master(1.16):

[jira] [Assigned] (FLINK-28783) Class ConfigOptions's example code have error.

[ https://issues.apache.org/jira/browse/FLINK-28783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-28783: -- Assignee: Aiden Gong > Class ConfigOptions's example code have error. >

[jira] [Assigned] (FLINK-28916) Add e2e test for create function using jar syntax

[ https://issues.apache.org/jira/browse/FLINK-28916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-28916: -- Assignee: dalongliu > Add e2e test for create function using jar syntax >

[jira] [Resolved] (FLINK-25485) JDBC connector implicitly append url options when use mysql

[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-25485. Fix Version/s: 1.16.0 Resolution: Resolved Resolved in master(1.16):

[jira] [Created] (FLINK-28881) PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream test failure

Leonard Xu created FLINK-28881: -- Summary: PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream test failure Key: FLINK-28881 URL: https://issues.apache.org/jira/browse/FLINK-28881

[jira] [Updated] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

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

[jira] [Commented] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

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

[jira] [Created] (FLINK-28789) TPC-DS tests failed due to release input gate for task failure

Leonard Xu created FLINK-28789: -- Summary: TPC-DS tests failed due to release input gate for task failure Key: FLINK-28789 URL: https://issues.apache.org/jira/browse/FLINK-28789 Project: Flink

[jira] [Commented] (FLINK-27384) In the Hive dimension table, when the data is changed on the original partition, the create_time configuration does not take effect

[ https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574566#comment-17574566 ] Leonard Xu commented on FLINK-27384: [~empcl] Could you also open PRs for release-1.4&1.15 branches?

[jira] [Commented] (FLINK-27384) In the Hive dimension table, when the data is changed on the original partition, the create_time configuration does not take effect

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

[jira] [Updated] (FLINK-27384) In the Hive dimension table, when the data is changed on the original partition, the create_time configuration does not take effect

[ https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-27384: --- Affects Version/s: 1.15.1 > In the Hive dimension table, when the data is changed on the original

[jira] [Assigned] (FLINK-27384) In the Hive dimension table, when the data is changed on the original partition, the create_time configuration does not take effect

[ https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-27384: -- Assignee: 陈磊 > In the Hive dimension table, when the data is changed on the original >

[jira] [Resolved] (FLINK-27806) Datagen add binary & varbinary type support

[ https://issues.apache.org/jira/browse/FLINK-27806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-27806. Fix Version/s: 1.16.0 Resolution: Implemented > Datagen add binary & varbinary type

[jira] [Commented] (FLINK-27806) Datagen add binary & varbinary type support

[ https://issues.apache.org/jira/browse/FLINK-27806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562915#comment-17562915 ] Leonard Xu commented on FLINK-27806: Implemented in master(1.16):

[jira] [Assigned] (FLINK-28370) Add close method for KafkaRecordSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-28370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-28370: -- Assignee: Hang Ruan > Add close method for KafkaRecordSerializationSchema >

[jira] [Created] (FLINK-28370) Add close method for KafkaRecordSerializationSchema

Leonard Xu created FLINK-28370: -- Summary: Add close method for KafkaRecordSerializationSchema Key: FLINK-28370 URL: https://issues.apache.org/jira/browse/FLINK-28370 Project: Flink Issue Type:

[jira] [Updated] (FLINK-27794) The primary key obtained from MySQL is incorrect by using MysqlCatalog

[ https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-27794: --- Fix Version/s: 1.15.2 > The primary key obtained from MySQL is incorrect by using MysqlCatalog >

[jira] [Comment Edited] (FLINK-27794) The primary key obtained from MySQL is incorrect by using MysqlCatalog

[ https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558456#comment-17558456 ] Leonard Xu edited comment on FLINK-27794 at 6/27/22 9:26 AM: - Fixed in:

[jira] [Resolved] (FLINK-27794) The primary key obtained from MySQL is incorrect by using MysqlCatalog

[ https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-27794. Resolution: Fixed > The primary key obtained from MySQL is incorrect by using MysqlCatalog >

[jira] [Commented] (FLINK-27794) The primary key obtained from MySQL is incorrect by using MysqlCatalog

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

[jira] [Resolved] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-27041. Resolution: Fixed > KafkaSource in batch mode failing on 0 messages in any topic partition >

[jira] [Comment Edited] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553946#comment-17553946 ] Leonard Xu edited comment on FLINK-27041 at 6/17/22 2:48 AM: - Fixed in

[jira] [Updated] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-27041: --- Fix Version/s: 1.15.1 1.14.6 > KafkaSource in batch mode failing on 0 messages

[jira] [Resolved] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-27762. Resolution: Fixed > Kafka WakeupException during handling splits changes >

[jira] [Updated] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-27762: --- Fix Version/s: 1.15.1 1.14.6 > Kafka WakeupException during handling splits

[jira] [Comment Edited] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554556#comment-17554556 ] Leonard Xu edited comment on FLINK-27762 at 6/17/22 2:44 AM: - fixed in

[jira] [Comment Edited] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553946#comment-17553946 ] Leonard Xu edited comment on FLINK-27041 at 6/16/22 8:31 AM: - Fixed in

[jira] [Comment Edited] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554556#comment-17554556 ] Leonard Xu edited comment on FLINK-27762 at 6/16/22 8:30 AM: - fixed in

[jira] [Commented] (FLINK-27762) Kafka WakeupException during handling splits changes

[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554556#comment-17554556 ] Leonard Xu commented on FLINK-27762: fixed in master(1.16):50c19d9f534f86e228f3e0937d92baf766a57165

[jira] [Commented] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553946#comment-17553946 ] Leonard Xu commented on FLINK-27041: Fixed in master(1.16):2b89dfe0d4c5c71a958fb1f07c5e6861e4bbe6a6

[jira] [Resolved] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

[ https://issues.apache.org/jira/browse/FLINK-24735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-24735. Resolution: Fixed > SQL client crashes with `Cannot add expression of different type to set` >

[jira] [Updated] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

[ https://issues.apache.org/jira/browse/FLINK-24735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24735: --- Fix Version/s: 1.15.1 (was: 1.14.5) > SQL client crashes with `Cannot add

[jira] [Comment Edited] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

[ https://issues.apache.org/jira/browse/FLINK-24735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540818#comment-17540818 ] Leonard Xu edited comment on FLINK-24735 at 5/23/22 11:30 AM: -- Fixed in:

[jira] [Commented] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

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

[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.16.0) > Properly implements processing-time temporal table join >

[jira] [Resolved] (FLINK-26588) Translate the new CAST documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-26588. Resolution: Resolved > Translate the new CAST documentation to Chinese >

[jira] [Updated] (FLINK-26588) Translate the new CAST documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26588: --- Fix Version/s: 1.16.0 > Translate the new CAST documentation to Chinese >

[jira] [Comment Edited] (FLINK-26588) Translate the new CAST documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534087#comment-17534087 ] Leonard Xu edited comment on FLINK-26588 at 5/10/22 4:51 PM: - Fixed in

[jira] [Updated] (FLINK-26588) Translate the new CAST documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-26588: --- Fix Version/s: 1.15.1 > Translate the new CAST documentation to Chinese >

[jira] [Commented] (FLINK-26588) Translate the new CAST documentation to Chinese

[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534087#comment-17534087 ] Leonard Xu commented on FLINK-26588: Fixed in master: a9605906aa0a4c9157717b7221ef38eeb70f5525

[jira] [Assigned] (FLINK-27263) Rename the metadata column to the user specified name in DDL

[ https://issues.apache.org/jira/browse/FLINK-27263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-27263: -- Assignee: Shengkai Fang > Rename the metadata column to the user specified name in DDL >

[jira] [Resolved] (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 resolved FLINK-26739. Resolution: Resolved Implemented in master: 58a41c9cae2d66404691dbfefb36e565fedcbb03 > Support

[jira] [Updated] (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 updated FLINK-26739: --- Fix Version/s: 1.16.0 > Support Hive 2.3.8 and 2.3.9 > > >

[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=17515771#comment-17515771 ] Leonard Xu commented on FLINK-26981: Thanks [~martijnvisser] for openning this ticket, nice feature

[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=17515139#comment-17515139 ] Leonard Xu edited comment on FLINK-26928 at 4/1/22 7:57 AM: Fixed in

[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=17515139#comment-17515139 ] Leonard Xu commented on FLINK-26928: Fixed in master(1.16):47a1f32676b0920e287fed9998b68e0a02ddfc3d

[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

[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=17509642#comment-17509642 ] Leonard Xu edited comment on FLINK-26422 at 3/22/22, 2:22 AM: -- Fixed in

[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=17509642#comment-17509642 ] Leonard Xu commented on FLINK-26422: Fixed in master(1.16) :

[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=17509151#comment-17509151 ] Leonard Xu edited comment on FLINK-26618 at 3/20/22, 4:50 AM: -- Fixed:

[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=17509151#comment-17509151 ] Leonard Xu commented on FLINK-26618: Fixed: master(1.16):1b041dbd9a781ef7a3927df45149be4f09e9ea7b

[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

[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=17503335#comment-17503335 ] Leonard Xu commented on FLINK-26099: Fixed in master(1.15): 38cfda517b7dfe42d3eaa2ecacdec64809e71e9f

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

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

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

[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=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=17494615#comment-17494615 ] Leonard Xu commented on FLINK-24407: master(1.15): 9f60c506366ae14405f0da487b3267aa336ec284 >

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

[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

[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

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

[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

[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

[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

[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

[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=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=17492357#comment-17492357 ] Leonard Xu commented on FLINK-26126: [~ruanhang1993] The blocker priority means we have to  fix to

[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=17491788#comment-17491788 ] Leonard Xu commented on FLINK-25286: I assigned these subtasks you raised PR to you [~ruanhang1993]

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

[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

[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

[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

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