问题一:根据官网的文档,是使用flink+holo 还是flink+paimon更好呀,更节约成本?
我这边的业务场景是需要把用户点击到下单完成的整个业务串起来,形成一个业务宽表,时延5分钟左右,根据官网的文档,是使用flink+holo 还是flink+paimon更好呀,更节约成本?
参考答案:
后者 更节约成本
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/641790
问题二:大家有Flink oracle同步doris的java工程吗?
大家有Flink oracle同步doris的java工程吗?参考一下
参考答案:
Flink 用于从 Oracle 数据库同步数据到 Doris(之前称为 Apache Doris 或 Palo,现在也称为 StarRocks)的 Java 工程通常会涉及到 Flink 的 DataStream API 或者 Table API/SQL。由于具体的实现会依赖于你的具体需求(例如,是全量同步还是增量同步,是否需要处理CDC,数据转换逻辑等),下面我将给出一个简化的示例框架,用于指导你如何构建这样的工程。
请注意,由于 Flink 和 Doris 的 API 可能会随着版本更新而发生变化,以下代码仅作为示例,并非可直接运行的代码。
- 添加 Maven 依赖
首先,你需要在 Maven pom.xml 文件中添加 Flink 和 JDBC 的依赖。
编写 Flink Job
以下是一个简化的 Flink Job 示例,它使用 DataStream API 从 Oracle 读取数据并写入 Doris。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/626081
问题三:不通过web界面的方式,flink on yarn怎么查看每个并行度处理数据的情况?
不通过web界面的方式,flink on yarn怎么查看每个并行度处理数据的情况,比如有几个并行度正在被使用,每个并行度处理多少数据等等?
参考答案:
可以通过metrics监控,配置metrics报告器(如JMX, Graphite等)导出这些数据,然后使用监控工具(如Grafana)展示
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/653347
问题四:同一个Flink任务能订阅多张Hologres的Binlog作为Source不?
同一个Flink任务能订阅多张Hologres的Binlog作为Source不?
参考答案:
可以的
关于本问题的更多回答可点击进行查看: