flink doris connector sql 关闭严格模式
时间: 2023-07-04 19:07:19 浏览: 100
如果您使用的是 Flink 1.12 及以上版本,则可以通过在 Flink SQL CLI 中设置参数 `execution.type.strict` 来关闭严格模式。具体操作如下:
1. 打开 Flink SQL CLI。
2. 执行以下命令:
```
SET execution.type.strict=false;
```
这将关闭严格模式。
请注意,关闭严格模式可能会导致某些查询的结果不正确,请根据实际情况酌情使用。
相关问题
flink doris connector 使用 flink sql 写入 doris 可以设置写入并发吗
是的,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 checkpoint 吗
是的,Flink Doris Connector 写入 DorisDB 时依赖 Flink 的 checkpoint 机制。Checkpoint 是 Flink 在运行过程中对状态进行持久化的机制,它可以保证在出现故障时能够恢复到最近一次的状态。在 Flink Doris Connector 中,写入 DorisDB 的数据也会被视为 Flink 状态的一部分,因此需要依赖 Flink 的 checkpoint 机制来保证数据的一致性和可靠性。