[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&focusedCommentId=17853908#comment-17853908 ] Hang Ruan commented on FLINK-30400: --- [~rmetzger] ,Thanks for the suggestion. I will w

[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&focusedCommentId=17852619#comment-17852619 ] Hang Ruan commented on FLINK-34445: --- [~mason6345] Sorry for my late response. I may n

[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&focusedCommentId=17847211#comment-17847211 ] Hang Ruan commented on FLINK-35296: --- Hi, [~清月] . What is the configuration of this my

[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&focusedCommentId=17846129#comment-17846129 ] Hang Ruan commented on FLINK-35109: --- [~fpaul] Thanks for your quick reply. I will work

[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&focusedCommentId=17845529#comment-17845529 ] Hang Ruan edited comment on FLINK-35109 at 5/11/24 3:26 AM:

[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&focusedCommentId=17845529#comment-17845529 ] Hang Ruan commented on FLINK-35109: --- I would like to help. Please assign this to me, t

[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&focusedCommentId=17831175#comment-17831175 ] Hang Ruan commented on FLINK-34445: --- Fine, I will take a look at this. Thanks ~ > Int

[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&focusedCommentId=17831119#comment-17831119 ] Hang Ruan commented on FLINK-34445: --- Sure, I would like to help in this part. When sho

[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&focusedCommentId=17827390#comment-17827390 ] Hang Ruan commented on FLINK-34683: --- I would like to help on this issue. Please assign

[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&focusedCommentId=17827329#comment-17827329 ] Hang Ruan commented on FLINK-34684: --- I would like to help on this issue. Please assign

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

[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&focusedCommentId=17798000#comment-17798000 ] Hang Ruan commented on FLINK-25509: --- Hi, [~martijnvisser] & [~lindong] . The Flink 1.

[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&focusedCommentId=17797117#comment-17797117 ] Hang Ruan commented on FLINK-31615: --- [~Wencong Liu] Sorry for the late reply.  I have

[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&focusedCommentId=17789146#comment-17789146 ] Hang Ruan commented on FLINK-33630: --- Hi, all.  I would like to help to resolve this p

[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&focusedCommentId=17764511#comment-17764511 ] Hang Ruan commented on FLINK-33013: --- Hi,all. I think we should reject this issue and k

[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&focusedCommentId=17764510#comment-17764510 ] Hang Ruan commented on FLINK-30400: --- Hi, all. I would like to help to check. Thanks.

[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&focusedCommentId=17760670#comment-17760670 ] Hang Ruan commented on FLINK-32798: --- [~renqs] [~zjureel] , I think we could complete t

[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&focusedCommentId=17758804#comment-17758804 ] Hang Ruan commented on FLINK-32798: --- Hi, all. [~renqs] [~zjureel]  I have modify the

[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&focusedCommentId=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 8:54 AM:

[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&focusedCommentId=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 4:12 AM:

[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&focusedCommentId=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 4:00 AM:

[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&focusedCommentId=17758339#comment-17758339 ] Hang Ruan edited comment on FLINK-32798 at 8/24/23 3:57 AM:

[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&focusedCommentId=17758339#comment-17758339 ] Hang Ruan commented on FLINK-32798: --- Hi, all. I have done some tests about this featur

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

[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&focusedCommentId=17757995#comment-17757995 ] Hang Ruan commented on FLINK-32798: --- [~zjureel] Hi, where should users put their jar?

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

[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&focusedCommentId=17757791#comment-17757791 ] Hang Ruan commented on FLINK-32799: --- I have also tested one insert and select. It look

[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&focusedCommentId=17756874#comment-17756874 ] Hang Ruan commented on FLINK-32799: --- Hi, all. I test this with the hive alter sql. It

[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&focusedCommentId=17754376#comment-17754376 ] Hang Ruan commented on FLINK-29039: --- This bug is the same as https://issues.apache.org

[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&focusedCommentId=17753887#comment-17753887 ] Hang Ruan commented on FLINK-32752: --- Hi, [~Sergey Nuyanzin] . I have raise a PR(https

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

[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&focusedCommentId=17753884#comment-17753884 ] Hang Ruan commented on FLINK-32752: --- Hi, all. I have tested this feature and it looks

[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&focusedCommentId=17753875#comment-17753875 ] Hang Ruan edited comment on FLINK-32786 at 8/14/23 3:04 AM:

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

[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&focusedCommentId=17753875#comment-17753875 ] Hang Ruan commented on FLINK-32786: --- I have implemented the interface in JDBC connecto

[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&focusedCommentId=17753125#comment-17753125 ] Hang Ruan commented on FLINK-32792: --- `drop partition` : * drop single partition succe

[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&focusedCommentId=17753119#comment-17753119 ] Hang Ruan commented on FLINK-32792: --- `show partitions` succeed. !show.png|width=642,h

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

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

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

[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&focusedCommentId=17753093#comment-17753093 ] Hang Ruan commented on FLINK-32792: --- !show-partitions.png|width=469,height=542! `Show

[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&focusedCommentId=17751437#comment-17751437 ] Hang Ruan commented on FLINK-32754: --- [~Yu Chen] [~yunta] ,Thanks for the issue. I hav

[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&focusedCommentId=17745524#comment-17745524 ] Hang Ruan commented on FLINK-32287: --- I would like to help. Please assign this to me. T

[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&focusedCommentId=17744421#comment-17744421 ] Hang Ruan commented on FLINK-29039: --- Hi, all. I would like to help. Please assign thi

[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&focusedCommentId=17740865#comment-17740865 ] Hang Ruan commented on FLINK-32555: --- I'd like to help. Please assign this to me. Thank

[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&focusedCommentId=17735266#comment-17735266 ] Hang Ruan commented on FLINK-32397: --- I would like to help. Please assign this to me. T

[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&focusedCommentId=17708640#comment-17708640 ] Hang Ruan commented on FLINK-31699: --- Thanks for suggestions. Actually I apply the chan

[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&focusedCommentId=17707916#comment-17707916 ] Hang Ruan commented on FLINK-31699: --- Hi, Danny, I would like to help. Please assign th

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

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

[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&focusedCommentId=17703547#comment-17703547 ] Hang Ruan commented on FLINK-31559: --- [~martijnvisser] , WDYT?   Thanks~ > Update the

[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&focusedCommentId=17703064#comment-17703064 ] Hang Ruan edited comment on FLINK-31483 at 3/21/23 7:08 AM:

[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&focusedCommentId=17703064#comment-17703064 ] Hang Ruan edited comment on FLINK-31483 at 3/21/23 7:06 AM:

[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&focusedCommentId=17703064#comment-17703064 ] Hang Ruan edited comment on FLINK-31483 at 3/21/23 7:05 AM:

[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&focusedCommentId=17703064#comment-17703064 ] Hang Ruan commented on FLINK-31483: --- Hi, [~ruibin] ,  I have found the mails about th

[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&focusedCommentId=17702109#comment-17702109 ] Hang Ruan commented on FLINK-31511: --- Hi, all,  I would like to help update this docum

[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&focusedCommentId=17701005#comment-17701005 ] Hang Ruan commented on FLINK-31483: --- Hi, Ruibin, Actually a deletion event(SplitsRemo

[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&focusedCommentId=17699319#comment-17699319 ] Hang Ruan commented on FLINK-30959: --- Hi, all, I would like to help to improve the doc

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

[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&focusedCommentId=17650103#comment-17650103 ] Hang Ruan commented on FLINK-25509: --- Hi, [~lindong] , I have read the FLIP and I am w

[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&focusedCommentId=17641728#comment-17641728 ] Hang Ruan edited comment on FLINK-29801 at 12/1/22 7:50 AM:

[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&focusedCommentId=17641728#comment-17641728 ] Hang Ruan commented on FLINK-29801: --- Hi, [~stevenz3wu] , For question 1,  we want to

[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&focusedCommentId=17638199#comment-17638199 ] Hang Ruan commented on FLINK-29801: --- Hi，[~MengYue] , what is your e-mail? I will send

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:53 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:48 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:48 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:42 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , I have created a FLIP about thi

[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&focusedCommentId=17636421#comment-17636421 ] Hang Ruan edited comment on FLINK-29801 at 11/21/22 3:52 AM: -

[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&focusedCommentId=17636421#comment-17636421 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , For the question 1, what I mean

[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&focusedCommentId=17635287#comment-17635287 ] Hang Ruan edited comment on FLINK-29801 at 11/17/22 11:02 AM:

[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&focusedCommentId=17635288#comment-17635288 ] Hang Ruan commented on FLINK-21000: --- Hi, [~kbendick] , Sorry for my late response. I

[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&focusedCommentId=17635288#comment-17635288 ] Hang Ruan edited comment on FLINK-21000 at 11/17/22 10:59 AM:

[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&focusedCommentId=17635287#comment-17635287 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , I may rely on this feature to a

[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&focusedCommentId=17629566#comment-17629566 ] Hang Ruan commented on FLINK-29492: --- [~fpaul] , sorry for my late response. I think t

[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&focusedCommentId=17616169#comment-17616169 ] Hang Ruan commented on FLINK-29492: --- I am interested in this bug. Maybe I could help t

[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&focusedCommentId=17565253#comment-17565253 ] Hang Ruan commented on FLINK-25545: --- [~RocMarshal] , thanks for your work. Please be f

[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&focusedCommentId=17565252#comment-17565252 ] Hang Ruan commented on FLINK-25546: --- [~Sergey Nuyanzin] , Thanks for your work. [~ren

[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&focusedCommentId=17562038#comment-17562038 ] Hang Ruan commented on FLINK-28370: --- I am interested in this ticket and I could help t

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

Title: Message Title Hang Ruan commented o

[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&focusedCommentId=17537970#comment-17537970 ] Hang Ruan commented on FLINK-24050: --- cc [~martijnvisser]  [~twalthr]  > Support prima

[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&focusedCommentId=17536499#comment-17536499 ] Hang Ruan commented on FLINK-24050: --- I am interested in this issue. Maybe I can help t

[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&focusedCommentId=17493613#comment-17493613 ] Hang Ruan commented on FLINK-26177: --- LGTM. The test case `testSavepoint` uses the sam

[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&focusedCommentId=17493045#comment-17493045 ] Hang Ruan edited comment on FLINK-25290 at 2/16/22, 8:00 AM: -

[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&focusedCommentId=17493045#comment-17493045 ] Hang Ruan edited comment on FLINK-25290 at 2/16/22, 7:57 AM: -

[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&focusedCommentId=17493045#comment-17493045 ] Hang Ruan commented on FLINK-25290: --- [~syhily] The feature about the dataStream sink t

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

  1   2   >