Commit 6eade69
committed
[Minor][FLINK-39168][cdc-connector-mysql] Cache split.splitId() result in a local variable to avoid calling the method twice per iteration: (apache#4288)
Co-authored-by: Thorne <syyfffy@163.com>1 parent 1bc4050 commit 6eade69
1 file changed
Lines changed: 3 additions & 2 deletions
File tree
- flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
390 | 390 | | |
391 | 391 | | |
392 | 392 | | |
393 | | - | |
| 393 | + | |
| 394 | + | |
394 | 395 | | |
395 | 396 | | |
396 | 397 | | |
397 | | - | |
| 398 | + | |
398 | 399 | | |
399 | 400 | | |
400 | 401 | | |
| |||
0 commit comments