探索云世界
Flink CDC里flink on yarn模式下，从MySQL同步到Doris报错是为什么啊？同任务在standalone模式下就能顺利运行，不知道是哪里的编码问题？
flink run-application -t yarn-application \
-Dyarn.application.name="Sync_Mysql_to_Doris" \
-Dfile.encoding=UTF-8 \
-Dsun.jnu.encoding=UTF-8 \
-Dyarn.provided.lib.dirs="hdfs://wxcluster/flink-dist" \
-Dexecution.checkpointing.interval=30s \
-Dparallelism.default=3 \
-c org.apache.doris.flink.tools.cdc.CdcTools \
hdfs://wxcluster/flink-jars/flink-doris-connector-1.18-1.5.2.jar \
mysql-sync-database \
--database ods \
--job-name sync_mysql_todoris \
--table-prefix ods \
--mysql-conf hostname=hadoop15 \
--mysql-conf username=root \
--mysql-conf password=admin \
--mysql-conf database-name=rhine3_user \
--including-tables "company" \
--sink-conf fenodes=hadoop43:8030,hadoop44:8030,hadoop45:8030 \
--sink-conf username=root \
--sink-conf password=admin \
--sink-conf jdbc-url=jdbc:mysql://hadoop43:9030 \
--sink-conf sink.label-prefix=doris_sink \
--table-conf replication_num=1
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
