[jira] [Commented] (FLINK-34754) [tidb-cdc]When the task runs for a period of time, there are only Resolved Events

[Flink CDC Issue Import (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-34754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828669#comment-17828669
 ] 

Flink CDC Issue Import commented on FLINK-34754:
------------------------------------------------

[Date: Thu Nov 17 15:44:46 CST 2022, Author: 
[wangxiaojing|https://github.com/wangxiaojing]]

2022-11-17 06:03:57,910 INFO  org.tikv.cdc.RegionCDCClient                      
           [] - submit event: CDCEvent[RESOLVED_TS] 
{resolvedTs=437422977945436229}
2022-11-17 06:03:57,910 DEBUG org.tikv.shade.io.grpc.netty.NettyClientHandler   
           [] - [id: 0xcfce7184, L:/xxxxxxxxx:41108 - R:/xxxxx:20160] INBOUND 
DATA: streamId=6359 padding=0 endStream=false length=22 
bytes=[0000000011120f08c3c0c80510c580a08898bc82|https://github.com/apache/flink-cdc/commit/0000000011120f08c3c0c80510c580a08898bc82]8906
2022-11-17 06:03:57,910 INFO  org.tikv.cdc.RegionCDCClient                      
           [] - submit event: CDCEvent[RESOLVED_TS] 
{resolvedTs=437422977945436229}
2022-11-17 06:03:57,910 DEBUG org.tikv.shade.io.grpc.netty.NettyClientHandler   
           [] - [id: 0xcfce7184, L:/xxxxxxx:41108 - R:/xxxxxxx:20160] INBOUND 
DATA: streamId=6353 padding=0 endStream=false length=22 
bytes=[0000000011120f0885eff00410c580a08898bc82|https://github.com/apache/flink-cdc/commit/0000000011120f0885eff00410c580a08898bc82]8906

> [tidb-cdc]When the task runs for a period of time, there are only Resolved 
> Events
> ---------------------------------------------------------------------------------
>
>                 Key: FLINK-34754
>                 URL: https://issues.apache.org/jira/browse/FLINK-34754
>             Project: Flink
>          Issue Type: Bug
>          Components: Flink CDC
>            Reporter: Flink CDC Issue Import
>            Priority: Major
>              Labels: github-import
>
> **Environment :**
>  - Flink version :  1.14.4
>  - Flink CDC version: 2.2 ,2.3 ,master
>  - Database and version: tidb5.0 and tidb5.1 
> **To Reproduce**
> flink-tidb-cdc table： A
> flink-jdbc table: B
> query:
> insert into A select * from B;
> desc:
> The task data is normal at the beginning of the program startup, but after 
> running for a period of time, the data is not updated.
> but there is no error message.
> The log:
> 2022-10-31 17:56:03,786 INFO  org.tikv.cdc.CDCClient                          
>              [] - handle resolvedTs: 437049141169750048, regionId: 1721083
> 2022-10-31 17:56:04,787 INFO  org.tikv.cdc.CDCClient                          
>              [] - handle resolvedTs: 437049141431894020, regionId: 1721083
> 2022-10-31 17:56:05,787 INFO  org.tikv.cdc.CDCClient                          
>              [] - handle resolvedTs: 437049141694038029, regionId: 1721083
> 2022-10-31 17:56:06,789 INFO  org.tikv.cdc.CDCClient                          
>              [] - handle resolvedTs: 437049141956182110, regionId: 1721083
> 2022-10-31 17:56:07,790 INFO  org.tikv.cdc.CDCClient                          
>              [] - handle resolvedTs: 437049142218326018, regionId: 1721083
> 2022-10-31 17:56:08,793 INFO  org.tikv.cdc.CDCClient                          
>              [] - handle resolvedTs: 437049142480470176, regionId: 1721083
> **Additional Description**
> If applicable, add screenshots to help explain your problem.
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/apache/flink-cdc/issues/1755
> Created by: [wangxiaojing|https://github.com/wangxiaojing]
> Labels: bug, 
> Created at: Thu Nov 17 11:44:16 CST 2022
> State: open



--
This message was sent by Atlassian Jira
(v8.20.10#820010)