[
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
[
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部分分区数据没有被消费，其次业务也多次从状态重启，但这个问题仍然存在。
解决方式：后续为了排查定位问题配置了
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:
[
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部分分区数据没有被消费，其次业务也多次从状态重启，但这个问题仍然存在。
解决方式：后续为了排查定位问题配置了
[
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
[
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
> ---
[
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
> ---
[
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
[
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
> ---
[
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
> ---
[
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
> ---
[
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
> ---
[
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
> ---
[
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
> ---
[
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:
[
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:
[
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/
[
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:
[
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
[
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
> ---
[
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
[ 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
> ---
[
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
[
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.
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
25 matches
Mail list logo
