Flink CDC Issue Import created FLINK-34813:
----------------------------------------------
Summary: [Bug] Using tidb-cdc to connect to the data source cpu
usage is always high
Key: FLINK-34813
URL: https://issues.apache.org/jira/browse/FLINK-34813
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: Flink CDC Issue Import
### Search before asking
- [X] I searched in the
[issues|https://github.com/ververica/flink-cdc-connectors/issues) and found
nothing similar.
### Flink version
17.1
### Flink CDC version
<dependency>
<groupId>com.ververica</groupId>
<artifactId>flink-connector-tidb-cdc</artifactId>
<version>2.4.1</version>
</dependency>
### Database and its version
tidb 5.4.3
### Minimal reproduce step
String xxx = "CREATE TABLE xxx (" +
" `id` STRING ,\n" +
" PRIMARY KEY (`id`) NOT ENFORCED" +
") WITH (" +
" 'connector' = 'tidb-cdc',\n" +
" 'tikv.grpc.timeout_in_ms' = '00000', " +
" 'pd-addresses' = '127.0.0.1:2379',\n" +
" 'database-name' = 'xxx'," +
" 'table-name' = 'xxx'" +
")";
tableEnv.executeSql(xxx);
String xxx = "CREATE TABLE xxx (" +
" `id` STRING ,\n" +
" PRIMARY KEY (`id`) NOT ENFORCED" +
") WITH (" +
" 'connector' = 'jdbc',\n" +
" 'url' =
'jdbc:mysql://xxx/xxx?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=true',\n"
+
" 'username' = 'xxx'," +
" 'password' = 'xxx'," +
" 'lookup.cache.max-rows' = '10000'," +
" 'lookup.cache.ttl' = '5s'," +
" 'table-name' = 'xxx'" +
")";
tableEnv.executeSql(xxx);
statementSet.addInsertSql(
"insert into xxx select * from xxx "];
### What did you expect to see?
After the synchronization is completed, the cpu usage is reduced
### What did you see instead?
After starting the job, the CPU usage is always very high.
### Anything else?
_No response_
### Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/2473
Created by: [tuyanzhang|https://github.com/tuyanzhang]
Labels: bug,
Created at: Fri Sep 08 17:54:27 CST 2023
State: open
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
