[jira] [Commented] (FLINK-35296) Flink mysql-cdc connector stops reading data

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847211#comment-17847211 ] Hang Ruan commented on FLINK-35296: --- Hi, [~清月] . What is the configuration of this mysql table and

[jira] [Commented] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

[ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846129#comment-17846129 ] Hang Ruan commented on FLINK-35109: --- [~fpaul] Thanks for your quick reply. I will work on it later. >

[jira] [Comment Edited] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

[ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845529#comment-17845529 ] Hang Ruan edited comment on FLINK-35109 at 5/11/24 3:26 AM: I would like to

[jira] [Commented] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

[ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845529#comment-17845529 ] Hang Ruan commented on FLINK-35109: --- I would like to help. Please assign this to me, thanks~ > Add

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831175#comment-17831175 ] Hang Ruan commented on FLINK-34445: --- Fine, I will take a look at this. Thanks ~ > Integrate new

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831119#comment-17831119 ] Hang Ruan commented on FLINK-34445: --- Sure, I would like to help in this part. When should I finish

[jira] [Commented] (FLINK-34683) "Developer Guide - Contribute to Flink CDC" Page for Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-34683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827390#comment-17827390 ] Hang Ruan commented on FLINK-34683: --- I would like to help on this issue. Please assign this to me.

[jira] [Commented] (FLINK-34684) "Developer Guide - Licenses" Page for Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-34684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827329#comment-17827329 ] Hang Ruan commented on FLINK-34684: --- I would like to help on this issue. Please assign this to me.

[jira] [Created] (FLINK-34586) Update the README in Flink CDC

Hang Ruan created FLINK-34586: - Summary: Update the README in Flink CDC Key: FLINK-34586 URL: https://issues.apache.org/jira/browse/FLINK-34586 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

Hang Ruan created FLINK-34585: - Summary: [JUnit5 Migration] Module: Flink CDC Key: FLINK-34585 URL: https://issues.apache.org/jira/browse/FLINK-34585 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34584) Change package name to org.apache.flink.cdc

Hang Ruan created FLINK-34584: - Summary: Change package name to org.apache.flink.cdc Key: FLINK-34584 URL: https://issues.apache.org/jira/browse/FLINK-34584 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798000#comment-17798000 ] Hang Ruan commented on FLINK-25509: --- Hi, [~martijnvisser] & [~lindong] . The Flink 1.18 has been

[jira] [Commented] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

[ https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797117#comment-17797117 ] Hang Ruan commented on FLINK-31615: --- [~Wencong Liu] Sorry for the late reply.  I have raised a PR to

[jira] [Closed] (FLINK-32862) Support INIT operation type to be compatible with DTS on Alibaba Cloud

[ https://issues.apache.org/jira/browse/FLINK-32862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan closed FLINK-32862. - Resolution: Won't Fix > Support INIT operation type to be compatible with DTS on Alibaba Cloud >

[jira] [Commented] (FLINK-33630) CoordinationResponse should be wrapped by SerializedValue in TaskOperatorEventGateway and JobMasterOperatorEventGateway

[ https://issues.apache.org/jira/browse/FLINK-33630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789146#comment-17789146 ] Hang Ruan commented on FLINK-33630: --- Hi, all.  I would like to help to resolve this problem. Please

[jira] [Commented] (FLINK-33013) Shade flink-connector-base info flink-sql-connector-connector

[ https://issues.apache.org/jira/browse/FLINK-33013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764511#comment-17764511 ] Hang Ruan commented on FLINK-33013: --- Hi,all. I think we should reject this issue and keep the provided

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764510#comment-17764510 ] Hang Ruan commented on FLINK-30400: --- Hi, all. I would like to help to check. Thanks. > Stop bundling

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760670#comment-17760670 ] Hang Ruan commented on FLINK-32798: --- [~renqs] [~zjureel] , I think we could complete this testing

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758804#comment-17758804 ] Hang Ruan commented on FLINK-32798: --- Hi, all. [~renqs] [~zjureel]  I have modify the code to test

[jira] [Comment Edited] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 8:54 AM: Hi, all.[~renqs]

[jira] [Comment Edited] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 4:12 AM: Hi, all. I have

[jira] [Comment Edited] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 4:00 AM: Hi, all. I have

[jira] [Comment Edited] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 3:57 AM: Hi, all. I have

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758339#comment-17758339 ] Hang Ruan commented on FLINK-32798: --- Hi, all. I have done some tests about this feature. 1.Create a

[jira] [Updated] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32798: -- Attachment: result.png > Release Testing: Verify FLIP-294: Support Customized Catalog Modification >

[jira] [Updated] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32798: -- Attachment: sqls.png > Release Testing: Verify FLIP-294: Support Customized Catalog Modification >

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757995#comment-17757995 ] Hang Ruan commented on FLINK-32798: --- [~zjureel] Hi, where should users put their jar? I do not find

[jira] [Updated] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32798: -- Attachment: test.png > Release Testing: Verify FLIP-294: Support Customized Catalog Modification >

[jira] [Commented] (FLINK-32799) Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner

[ https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757791#comment-17757791 ] Hang Ruan commented on FLINK-32799: --- I have also tested one insert and select. It looks good. >

[jira] [Updated] (FLINK-32799) Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner

[ https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32799: -- Attachment: lib.png > Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner >

[jira] [Commented] (FLINK-32799) Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner

[ https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17756874#comment-17756874 ] Hang Ruan commented on FLINK-32799: --- Hi, all. I test this with the hive alter sql. It seems good.

[jira] [Updated] (FLINK-32799) Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner

[ https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32799: -- Attachment: hive.png > Release Testing: Verify FLINK-26603 -Decouple Hive with Flink planner >

[jira] [Commented] (FLINK-29039) RowData produced by LineBytesInputFormat is reused, but DeserializationSchemaAdapter#Reader only shallow copies produced data, thus result will always be the last row

[ https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754376#comment-17754376 ] Hang Ruan commented on FLINK-29039: --- This bug is the same as

[jira] [Created] (FLINK-32862) Support INIT operation type to be compatible with DTS on Alibaba Cloud

Hang Ruan created FLINK-32862: - Summary: Support INIT operation type to be compatible with DTS on Alibaba Cloud Key: FLINK-32862 URL: https://issues.apache.org/jira/browse/FLINK-32862 Project: Flink

[jira] [Commented] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753887#comment-17753887 ] Hang Ruan commented on FLINK-32752: --- Hi, [~Sergey Nuyanzin] . I have raise a

[jira] [Updated] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32752: -- Attachment: part1.png part2.png > Release Testing: Verify FLINK-24909 SQL syntax

[jira] [Commented] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753884#comment-17753884 ] Hang Ruan commented on FLINK-32752: --- Hi, all. I have tested this feature and it looks good.

[jira] [Comment Edited] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753875#comment-17753875 ] Hang Ruan edited comment on FLINK-32786 at 8/14/23 3:04 AM: I have

[jira] [Updated] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32786: -- Attachment: after.png before.png truncate.png > Release Testing:

[jira] [Commented] (FLINK-32786) Release Testing: Verify FLIP-302: Support TRUNCATE TABLE statement in batch mode

[ https://issues.apache.org/jira/browse/FLINK-32786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753875#comment-17753875 ] Hang Ruan commented on FLINK-32786: --- I have implemented the interface in JDBC connector for MySQL. See

[jira] [Commented] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753125#comment-17753125 ] Hang Ruan commented on FLINK-32792: --- `drop partition` : * drop single partition succeed. * drop two

[jira] [Updated] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32792: -- Attachment: drop.png > Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[jira] [Commented] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753119#comment-17753119 ] Hang Ruan commented on FLINK-32792: --- `show partitions` succeed. !show.png|width=642,height=344!

[jira] [Updated] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32792: -- Attachment: show.png > Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[jira] [Updated] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32792: -- Attachment: add.png > Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement >

[jira] [Updated] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32792: -- Attachment: show-partitions.png > Release Testing: Verify FLINK-27237 - Partitioned table statement

[jira] [Updated] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-32792: -- Attachment: (was: show-partitions.png) > Release Testing: Verify FLINK-27237 - Partitioned table

[jira] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792 ] Hang Ruan deleted comment on FLINK-32792: --- was (Author: ruanhang1993): !show-partitions.png|width=469,height=542! `Show partitions` succeed.  > Release Testing: Verify FLINK-27237 -

[jira] [Commented] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753093#comment-17753093 ] Hang Ruan commented on FLINK-32792: --- !show-partitions.png|width=469,height=542! `Show partitions`

[jira] [Commented] (FLINK-32754) Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE

[ https://issues.apache.org/jira/browse/FLINK-32754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751437#comment-17751437 ] Hang Ruan commented on FLINK-32754: --- [~Yu Chen] [~yunta] ,Thanks for the issue. I have opened a

[jira] [Commented] (FLINK-32287) Add doc for truncate table statement

[ https://issues.apache.org/jira/browse/FLINK-32287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17745524#comment-17745524 ] Hang Ruan commented on FLINK-32287: --- I would like to help. Please assign this to me. Thanks. > Add

[jira] [Commented] (FLINK-29039) RowData produced by LineBytesInputFormat is reused, but DeserializationSchemaAdapter#Reader only shallow copies produced data, thus result will always be the last row

[ https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744421#comment-17744421 ] Hang Ruan commented on FLINK-29039: --- Hi, all. I would like to help. Please assign this issue to me.

[jira] [Commented] (FLINK-32555) Add a page to show SIGMOD System Awards for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740865#comment-17740865 ] Hang Ruan commented on FLINK-32555: --- I'd like to help. Please assign this to me. Thanks. > Add a page

[jira] [Commented] (FLINK-32397) Add doc for add/drop/show partition

[ https://issues.apache.org/jira/browse/FLINK-32397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735266#comment-17735266 ] Hang Ruan commented on FLINK-32397: --- I would like to help. Please assign this to me. Thanks. > Add

[jira] [Commented] (FLINK-31699) JDBC nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708640#comment-17708640 ] Hang Ruan commented on FLINK-31699: --- Thanks for suggestions. Actually I apply the changes in PR#31 and

[jira] [Commented] (FLINK-31699) JDBC nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707916#comment-17707916 ] Hang Ruan commented on FLINK-31699: --- Hi, Danny, I would like to help. Please assign this to me, thanks

[jira] [Updated] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

[ https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-31615: -- Description: The query_state_warning in "Table API" page of "Table API & SQL"  is still in English.

[jira] [Updated] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

[ https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-31615: -- Description: The query_state_warning in  > Fix some parts forgot to translate in "Table API" page of

[jira] [Created] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

Hang Ruan created FLINK-31615: - Summary: Fix some parts forgot to translate in "Table API" page of "Table API & SQL" Key: FLINK-31615 URL: https://issues.apache.org/jira/browse/FLINK-31615 Project:

[jira] [Commented] (FLINK-31559) Update the flink version to 1.18-SNAPSHOT in flink-connector-kafka

[ https://issues.apache.org/jira/browse/FLINK-31559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703547#comment-17703547 ] Hang Ruan commented on FLINK-31559: --- [~martijnvisser] , WDYT?   Thanks~ > Update the flink version to

[jira] [Created] (FLINK-31559) Update the flink version to 1.18-SNAPSHOT in flink-connector-kafka

Hang Ruan created FLINK-31559: - Summary: Update the flink version to 1.18-SNAPSHOT in flink-connector-kafka Key: FLINK-31559 URL: https://issues.apache.org/jira/browse/FLINK-31559 Project: Flink

[jira] [Comment Edited] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703064#comment-17703064 ] Hang Ruan edited comment on FLINK-31483 at 3/21/23 7:08 AM: Hi, [~ruibin] , 

[jira] [Comment Edited] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703064#comment-17703064 ] Hang Ruan edited comment on FLINK-31483 at 3/21/23 7:06 AM: Hi, [~ruibin] , 

[jira] [Comment Edited] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703064#comment-17703064 ] Hang Ruan edited comment on FLINK-31483 at 3/21/23 7:05 AM: Hi, [~ruibin] , 

[jira] [Commented] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703064#comment-17703064 ] Hang Ruan commented on FLINK-31483: --- Hi, [~ruibin] ,  I have found the mails about this part. Hope it

[jira] [Created] (FLINK-31511) Translate documentation sql_functions_zh.yml to the latest version

Hang Ruan created FLINK-31511: - Summary: Translate documentation sql_functions_zh.yml to the latest version Key: FLINK-31511 URL: https://issues.apache.org/jira/browse/FLINK-31511 Project: Flink

[jira] [Commented] (FLINK-31511) Translate documentation sql_functions_zh.yml to the latest version

[ https://issues.apache.org/jira/browse/FLINK-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702109#comment-17702109 ] Hang Ruan commented on FLINK-31511: --- Hi, all,  I would like to help update this document as some

[jira] [Commented] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701005#comment-17701005 ] Hang Ruan commented on FLINK-31483: --- Hi, Ruibin, Actually a deletion event(SplitsRemoval) is planned

[jira] [Commented] (FLINK-30959) Improve the documentation of UNIX_TIMESTAMP for different argument format

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699319#comment-17699319 ] Hang Ruan commented on FLINK-30959: --- Hi, all, I would like to help to improve the document. Please

[jira] [Created] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

Hang Ruan created FLINK-31268: - Summary: OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint Key: FLINK-31268 URL: https://issues.apache.org/jira/browse/FLINK-31268

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17650103#comment-17650103 ] Hang Ruan commented on FLINK-25509: --- Hi, [~lindong] , I have read the FLIP and I am willing to help

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641728#comment-17641728 ] Hang Ruan edited comment on FLINK-29801 at 12/1/22 7:50 AM: Hi,

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641728#comment-17641728 ] Hang Ruan commented on FLINK-29801: --- Hi, [~stevenz3wu] , For question 1,  we want to provide some

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638199#comment-17638199 ] Hang Ruan commented on FLINK-29801: --- Hi，[~MengYue] , what is your e-mail? I will send an e-mail to

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:53 AM: - Hi, [~MengYue]

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:48 AM: - Hi, [~MengYue]

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:48 AM: - Hi, [~MengYue]

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:42 AM: - Hi, [~MengYue]

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638076#comment-17638076 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , I have created a FLIP about this issue. Could

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636421#comment-17636421 ] Hang Ruan edited comment on FLINK-29801 at 11/21/22 3:52 AM: - Hi, [~MengYue]

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636421#comment-17636421 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , For the question 1, what I means is better to

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635287#comment-17635287 ] Hang Ruan edited comment on FLINK-29801 at 11/17/22 11:02 AM: -- Hi,

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

[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635288#comment-17635288 ] Hang Ruan commented on FLINK-21000: --- Hi, [~kbendick] , Sorry for my late response. I will continue to

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

[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635288#comment-17635288 ] Hang Ruan edited comment on FLINK-21000 at 11/17/22 10:59 AM: -- Hi,

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635287#comment-17635287 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , I may rely on this feature to accomplish

[jira] [Commented] (FLINK-29492) Kafka exactly-once sink causes OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629566#comment-17629566 ] Hang Ruan commented on FLINK-29492: --- [~fpaul] , sorry for my late response. I think this bug should

[jira] [Commented] (FLINK-29492) Kafka exactly-once sink causes OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-29492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616169#comment-17616169 ] Hang Ruan commented on FLINK-29492: --- I am interested in this bug. Maybe I could help to take a look at

[jira] [Commented] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565253#comment-17565253 ] Hang Ruan commented on FLINK-25545: --- [~RocMarshal] , thanks for your work. Please be free to take this

[jira] [Commented] (FLINK-25546) [JUnit5 Migration] Module: flink-connector-base

[ https://issues.apache.org/jira/browse/FLINK-25546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565252#comment-17565252 ] Hang Ruan commented on FLINK-25546: --- [~Sergey Nuyanzin] , Thanks for your work. [~renqs], could you

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

[ https://issues.apache.org/jira/browse/FLINK-28370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562038#comment-17562038 ] Hang Ruan commented on FLINK-28370: --- I am interested in this ticket and I could help to resolve this

[jira] [Commented] (FLINK-25315) Add new extensions and classes to help the JUnit5 migration

Title: Message Title Hang Ruan commented

[jira] [Commented] (FLINK-24050) Support primary keys on metadata columns

[ https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537970#comment-17537970 ] Hang Ruan commented on FLINK-24050: --- cc [~martijnvisser]  [~twalthr]  > Support primary keys on

[jira] [Commented] (FLINK-24050) Support primary keys on metadata columns

[ https://issues.apache.org/jira/browse/FLINK-24050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536499#comment-17536499 ] Hang Ruan commented on FLINK-24050: --- I am interested in this issue. Maybe I can help to improve this

[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493613#comment-17493613 ] Hang Ruan commented on FLINK-26177: --- LGTM. The test case `testSavepoint` uses the same code as the

[jira] [Comment Edited] (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:comment-tabpanel=17493045#comment-17493045 ] Hang Ruan edited comment on FLINK-25290 at 2/16/22, 8:00 AM: - Hi, [~syhily]

[jira] [Comment Edited] (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:comment-tabpanel=17493045#comment-17493045 ] Hang Ruan edited comment on FLINK-25290 at 2/16/22, 7:57 AM: - [~syhily] The

[jira] [Commented] (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:comment-tabpanel=17493045#comment-17493045 ] Hang Ruan commented on FLINK-25290: --- [~syhily] The feature about the dataStream sink test suite has

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

[ https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-26126: -- Component/s: Connectors / Common > Sink V2 will cause error numRecordsOut metric >

[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=17492390#comment-17492390 ] Hang Ruan commented on FLINK-26126: --- The Kafka sink is already using the sink v2 interface in the

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

Hang Ruan created FLINK-26126: - Summary: Sink V2 will cause error numRecordsOut metric Key: FLINK-26126 URL: https://issues.apache.org/jira/browse/FLINK-26126 Project: Flink Issue Type: Bug

  1   2   >