flink-cdc
flink-cdc copied to clipboard
Flink CDC is a streaming data integration tool
The value of option `connector.timeout` needs to be checked at compile time.
Improve jdbc connection pool initialization failure message.
Currently, Flink CDC supports both new Flink config file `config.yaml` and fallback legacy config file `flink-conf.yaml`. However, a false-alarm "File Not Found" exception will be printed in legacy compatible mode....
Since MySQL does not support the ability to quickly locate an binlog offset through a timestamp, the current logic for starting from a timestamp is to begin from the earliest...
Current, subclasses of JdbcSourceChunkSplitter almost share same code, but each have one copy. It's hard for later maintenance. Thus, this Jira aim to move same code from multiple subclasses to...
## What is the purpose of the change Translate "Deployment - YARN" page into Chinese. The page url is https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/zh/docs/deployment/yarn/ The markdown file is located in `flink-cdc/docs/content.zh/docs/deployment/yarn.md` ## Brief change...
Changes: - Enable build check for pr - Add `release 3.1` doc