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 checkpoint 吗

是的，Flink Doris Connector 写入 DorisDB 时依赖 Flink 的 checkpoint 机制。Checkpoint 是 Flink 在运行过程中对状态进行持久化的机制，它可以保证在出现故障时能够恢复到最近一次的状态。在 Flink Doris Connector 中，写入 DorisDB 的数据也会被视为 Flink 状态的一部分，因此需要依赖 Flink 的 checkpoint 机制来保证数据的一致性和可靠性。

flink doris connector 使用 flink sql 写入 doris 可以设置写入并发吗

是的，Flink Doris Connector 在使用 Flink SQL 写入 Doris 时，也可以设置并发度。您可以在创建 Flink SQL Job 时，使用 `SET` 命令设置并发度，例如：

SET flink.parallelism=2;
INSERT INTO doris_table SELECT * FROM source_table;

上述代码中，`flink.parallelism` 参数设置了并发度为 2，即使用 2 个并发任务进行写入。您可以根据实际需求设置不同的并发度。注意，该参数只在当前 Flink SQL Job 运行时有效，不会影响其他 Job 或全局并发设置。