umerwhu commented on issue #2600:
URL: https://github.com/apache/flink-cdc/issues/2600#issuecomment-2649686721
source:
type: mysql
hostname: 127.0.0.1
port: 3306
username: de*****
password: ******
tables: ECommerceData.ecom_customers # Specify the tables to capture
changes from (use .* to capture all)
# server-id: 5400-5404
# server-time-zone: UTC
sink:
type: doris
fenodes: 127.0.0.1:29030
username: root
password: ""
pipeline:
name: Sync MySQL Database to Doris
parallelism: 2
[root@d7a4ade0ac24 flink-cdc-3.3.0]# ./bin/flink-cdc.sh
/opt/flink/flink-cdc-3.3.0/bin/mysql-to-doris.yaml
Exception in thread "main" java.lang.RuntimeException: Cannot find factory
with identifier "doris" in the classpath.
Available factory classes are:
org.apache.flink.cdc.connectors.mysql.factory.MySqlDataSourceFactory
at
org.apache.flink.cdc.composer.utils.FactoryDiscoveryUtils.getFactoryByIdentifier(FactoryDiscoveryUtils.java:65)
at
org.apache.flink.cdc.composer.flink.translator.DataSinkTranslator.createDataSink(DataSinkTranslator.java:65)
at
org.apache.flink.cdc.composer.flink.FlinkPipelineComposer.translate(FlinkPipelineComposer.java:132)
at
org.apache.flink.cdc.composer.flink.FlinkPipelineComposer.compose(FlinkPipelineComposer.java:99)
at org.apache.flink.cdc.cli.CliExecutor.run(CliExecutor.java:89)
at org.apache.flink.cdc.cli.CliFrontend.main(CliFrontend.java:74)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
