全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

使用dinky执行flink sql从kafka同步数据一般需要设置哪些环境变量？

提问者：帅平问题分类：大数据

发布于：1个月前 (03-24) IP属地：

1 个回答

孤岛少女情

需要设置的环境变量大致有：

SET 'execution.checkpointing.interval' = '10s';
SET 'table.exec.state.ttl'= '8640000';
SET 'table.exec.mini-batch.enabled' = 'true';
SET 'table.exec.mini-batch.allow-latency' = '60s';
SET 'table.exec.mini-batch.size' = '10000';
SET 'table.local-time-zone' = 'Asia/Shanghai';
SET 'table.exec.sink.not-null-enforcer'='DROP';

发布于：1个月前 (03-24) IP属地：

我来回答