Xie Yi

[tidb-cdc] data loss when switch from snapshot read to change event read

5

**Describe the bug(Please use English)** data loss when switch from snapshot read to change event read **Environment :** - Flink version : flink 1.14 - Flink CDC version: 2.2.0 -...

[bug] RegionCDCClient grpc stream don't receive ChangeDataEvent from tikv store after several hours,because tikv region transfer leader

9

## Bug Report ### 1. Describe the bug RegionCDCClient grpc stream don't receive ChangeDataEvent from tikv server after several hours,because tikv region transfer leader ### 2. Minimal reproduce step (Required)...

[tidb-cdc]KeyRange in TableKeyRangeUtils distribution is unreasonable.Scan tidb table is not divided between different subtasks

4

**Describe the bug(Please use English)** #### KeyRange in TableKeyRangeUtils distribution is unreasonable. Scan tidb table is not divided between different subtasks **Environment :** - Flink version : flink 1.14 -...

[Bug]: Spark terminal don't support write paimon under hadoop2.x for spark3.1

2

### What happened? Paimon spark writer only support spark 3.2+ Amoro-Spark terminal version is 3.1.2 when build with hadoop 2.x ### Affects Versions master/0.6.x ### What engines are you seeing...

https://issues.apache.org/jira/browse/FLINK-35245 add metrcis: currentFetchEventTimeLag, currentEmitEventTimeLag, sourceIdleTime for TiKVRichParallelSourceFunction

[FLINK-35244][cdc-connector][tidb] Move package for flink-connector-tidb-cdc test

1

see https://issues.apache.org/jira/browse/FLINK-35244 test case for flink-connector-tidb-cdc should under `org.apache.flink.cdc.connectors.tidb` package instead of `org.apache.flink.cdc.connectors`

[tidb] Add metrics for tidb connector

2

add metrcis: currentFetchEventTimeLag, currentEmitEventTimeLag, sourceIdleTime for TiKVRichParallelSourceFunction issue: https://github.com/ververica/flink-cdc-connectors/issues/985

[Bug]fix Update Job and upload jar, then build job failed

1

## What changes were proposed in this pull request Issue Number: close https://github.com/apache/incubator-streampark/issues/4090 ## Brief change log ## Verifying this change This change is a trivial rework / code cleanup...

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### Java Version 1.8 ### Scala Version 2.11.x ### StreamPark Version dev ###...