开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC里flink on yarn模式下,从MySQL同步到Doris报错是为什么啊?

Flink CDC里flink on yarn模式下,从MySQL同步到Doris报错是为什么啊?同任务在standalone模式下就能顺利运行,不知道是哪里的编码问题?c9a1bc4a7aab2e16488bb33785135f35.png6a4e374adbea4bd6510d40b0c2d85339.pngflink 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

展开
收起
小小鹿鹿鹿 2024-02-06 19:50:43 69 0
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    深度学习+大数据 TensorFlow on Yarn 立即下载
    Docker on Yarn 微服务实践 立即下载
    深度学习+大数据-TensorFlow on Yarn 立即下载