flink doris connector 使用 flink sql 写入 doris 可以设置写入并发吗
时间: 2023-07-01 18:17:44 浏览: 113
是的,Flink Doris Connector 在使用 Flink SQL 写入 Doris 时,也可以设置并发度。您可以在创建 Flink SQL Job 时,使用 `SET` 命令设置并发度,例如:
```sql
SET flink.parallelism=2;
INSERT INTO doris_table SELECT * FROM source_table;
```
上述代码中,`flink.parallelism` 参数设置了并发度为 2,即使用 2 个并发任务进行写入。您可以根据实际需求设置不同的并发度。注意,该参数只在当前 Flink SQL Job 运行时有效,不会影响其他 Job 或全局并发设置。
相关问题
flink doris connector 写入 doris 可以设置写入并发吗
是的,Flink Doris Connector 可以设置写入并发。您可以通过 `setParallelism(int parallelism)` 方法来设置并发数。该方法将并发度设置为指定的整数值。并发度的值越高,写入操作的吞吐量就越大,但也会增加系统资源的使用量。建议根据实际需求和系统资源进行设置。
flink doris connector 写 doris 依赖 flink checkpoint 吗
是的,Flink Doris Connector 写入 DorisDB 时依赖 Flink 的 checkpoint 机制。Checkpoint 是 Flink 在运行过程中对状态进行持久化的机制,它可以保证在出现故障时能够恢复到最近一次的状态。在 Flink Doris Connector 中,写入 DorisDB 的数据也会被视为 Flink 状态的一部分,因此需要依赖 Flink 的 checkpoint 机制来保证数据的一致性和可靠性。