Leonard Xu
Leonard Xu
Please comment under this issue to propose your wanted feature. ## Feature Development * [ ] #450 * [ ] #456 * [ ] #997 * [ ] #851 *...
We can add `currentFetchEventTimeLag`, `currentEmitEventTimeLag` and `sourceIdleTime` metrics for oceanbase cdc connector just like we did in other connector.
## Good For Newcomers * [x] #356 * [ ] #345 * [x] #346 * [x] #370 * [x] #381 * [x] #343 * [x] #249 * [x] #162 *...
We only catch Exception in ChunkSplitter, the Error can not catch in ChunkSplitter. If user meet driver conflicts issue, the Error will be thrown but we can not catch it...
## Bug Report ### 1. Describe the bug When I use CDCClient#handleErrorEvent, the method CDCClient#getMinResolvedTs and CDCClient#getMaxResolvedTs occurs NPE error. ### 2. Minimal reproduce step (Required) Start a CDCClient and...
Is your feature request related to a problem? Please describe. Adapt Postgres CDC Connector to the abstraction framework of https://github.com/ververica/flink-cdc-connectors/issues/724
### Search before asking - [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar. ### Paimon version d44741d6aaa43a73a20ef96979a8ded72efc2f6c ### Compute Engine Flink ### Minimal reproduce step https://github.com/apache/incubator-paimon/actions/runs/4464527298/jobs/7840743848 ### What...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar. ### Motivation Skip code CI tests if the PR only contains docs change to save...
## Motivation This is an umbrella issue for Flink CDC 3.1 version ## Solution **[module] flink-cdc-common** * [x] #2857 * [ ] #2936 * [x] #2943 **[module] flink-cdc-cli** * [...