flink doris connector 使用 flink sql 写入 doris 可以设置写入并发吗
时间: 2023-07-01 17:17:44 浏览: 223
是的,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 sql 关闭严格模式
如果您使用的是 Flink 1.12 及以上版本,则可以通过在 Flink SQL CLI 中设置参数 `execution.type.strict` 来关闭严格模式。具体操作如下:
1. 打开 Flink SQL CLI。
2. 执行以下命令:
```
SET execution.type.strict=false;
```
这将关闭严格模式。
请注意,关闭严格模式可能会导致某些查询的结果不正确,请根据实际情况酌情使用。
阅读全文