问答 2024-03-26 来自:开发者社区

我现在在做flink cdc2doris的操作目前出现了以下问题,要怎么解决?

我现在在做flink cdc2doris的操作目前出现了以下问题:原先同步10张表,都是先全量再增量同步的(scan.startup.mode=initial),现在新加两张表,配置从最早的binlog开始同步(scan.startup.mode=earliest-offset),从savepoint启动后发现配置没生效,新加的两张表还是先全量再增量。

问答 2023-09-13 来自:开发者社区

我用 flink 来连接 kafka和 hbase 进行 etl 等相关操作,怎么解决啊?

想请教一个问题,我用 flink 来连接 kafka和 hbase 进行 etl 等相关操作,我的 kafka 是用的阿里云,设置的 zookeeper.sasl.client=false, 然后 hbase 用的华为云,设置的 zookeeper.sasl.client=true, 然后这两个表进行join之后,就读取不到 hbase 的数据了,然后这个 zookeeper.sasl.clie....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注