[jira] [Updated] (FLINK-35911) Flink kafka-source connector

[ https://issues.apache.org/jira/browse/FLINK-35911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35911: -- Description: 问题描述：业务反馈数据丢失，经排查发现是上游Kafka-Source部分分区数据没有被消费，其次业务也多次从状态重启，但这个问题仍然存在。 解决方式：后续为了排查定位问题配置了

[jira] [Created] (FLINK-35911) Flink kafka-source connector

Gang Yang created FLINK-35911: - Summary: Flink kafka-source connector Key: FLINK-35911 URL: https://issues.apache.org/jira/browse/FLINK-35911 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-35911) Flink kafka-source connector

[ https://issues.apache.org/jira/browse/FLINK-35911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35911: -- Description: 问题描述：业务反馈数据丢失，经排查发现是上游Kafka-Source部分分区数据没有被消费，其次业务也多次从状态重启，但这个问题仍然存在。 解决方式：后续为了排查定位问题配置了

[jira] [Updated] (FLINK-35911) Flink kafka-source connector

[ https://issues.apache.org/jira/browse/FLINK-35911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35911: -- Description: Problem description: Business feedback data is lost. After investigation, it is found th

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

Gang Yang created FLINK-35296: - Summary: Flink mysql-cdc connector stops reading data Key: FLINK-35296 URL: https://issues.apache.org/jira/browse/FLINK-35296 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Description: *Background:* Consume sub-database and sub-table data through regular expressions, scan.

[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=17846152#comment-17846152 ] Gang Yang commented on FLINK-35296: --- 是的，已经检查过，分表最大数据量是1315883，最小是443151，差距不超过三倍 > Fli

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

[ https://issues.apache.org/jira/browse/FLINK-35296 ] Gang Yang deleted comment on FLINK-35296: --- was (Author: 清月): 是的，已经检查过，分表最大数据量是1315883，最小是443151，差距不超过三倍 > Flink mysql-cdc connector stops reading data > ---

[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=17846153#comment-17846153 ] Gang Yang commented on FLINK-35296: --- Yes, I have checked it. The maximum data volume o

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-14-11-25-55-565.png > Flink mysql-cdc connector stops reading data > ---

[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=17846157#comment-17846157 ] Gang Yang commented on FLINK-35296: --- This abnormal situation occurs not only in sub-da

[jira] [Comment Edited] (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=17846157#comment-17846157 ] Gang Yang edited comment on FLINK-35296 at 5/14/24 3:28 AM:

[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=17848028#comment-17848028 ] Gang Yang commented on FLINK-35296: --- !https://alidocs.dingtalk.com/core/api/resources/

[jira] [Comment Edited] (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=17848028#comment-17848028 ] Gang Yang edited comment on FLINK-35296 at 5/21/24 2:18 AM:

[jira] [Comment Edited] (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=17848028#comment-17848028 ] Gang Yang edited comment on FLINK-35296 at 5/21/24 2:19 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-10-51-08-452.png > Flink mysql-cdc connector stops reading data > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-10-51-17-196.png > Flink mysql-cdc connector stops reading data > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-10-52-02-530.png > Flink mysql-cdc connector stops reading data > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-10-52-52-827.png > Flink mysql-cdc connector stops reading data > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-10-53-05-634.png > Flink mysql-cdc connector stops reading data > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-10-53-54-946.png > Flink mysql-cdc connector stops reading data > ---

[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=17848033#comment-17848033 ] Gang Yang commented on FLINK-35296: --- Hi，[~ruanhang1993] ，The following is a screenshot

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-11-16-01-719.png > Flink mysql-cdc connector stops reading data > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gang Yang updated FLINK-35296: -- Attachment: image-2024-05-21-11-17-13-441.png > Flink mysql-cdc connector stops reading data > ---

[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=17848037#comment-17848037 ] Gang Yang commented on FLINK-35296: --- Hi，[~ruanhang1993] ，Below is a screenshot of the