flink doris connector 写 doris 依赖 flink checkpoint 吗
时间: 2023-09-14 07:03:01 浏览: 239
是的,Flink Doris Connector 写入 DorisDB 时依赖 Flink 的 checkpoint 机制。Checkpoint 是 Flink 在运行过程中对状态进行持久化的机制,它可以保证在出现故障时能够恢复到最近一次的状态。在 Flink Doris Connector 中,写入 DorisDB 的数据也会被视为 Flink 状态的一部分,因此需要依赖 Flink 的 checkpoint 机制来保证数据的一致性和可靠性。
相关问题
flink doris connector 写 apache doris 依赖 flink checkpoint 吗
是的,Flink Doris Connector 写入 Apache Doris(原名 Apache DorisDB)同样依赖 Flink 的 checkpoint 机制。Checkpoint 是 Flink 在运行过程中对状态进行持久化的机制,它可以保证在出现故障时能够恢复到最近一次的状态。在 Flink Doris Connector 中,写入 Apache Doris 的数据也会被视为 Flink 状态的一部分,因此需要依赖 Flink 的 checkpoint 机制来保证数据的一致性和可靠性。
flink doris connector 写入 doris 可以设置写入并发吗
是的,Flink Doris Connector 可以设置写入并发。您可以通过 `setParallelism(int parallelism)` 方法来设置并发数。该方法将并发度设置为指定的整数值。并发度的值越高,写入操作的吞吐量就越大,但也会增加系统资源的使用量。建议根据实际需求和系统资源进行设置。
阅读全文