Flink CDC里我写了一个look up hint 没有生效,,flink 版本1.16 ,不知道啥原因?
如果你在Flink CDC中写了一个look up hint但没有生效,你可以尝试以下几种方法:
检查你的look up hint是否正确。确保你在正确的表和字段上使用了look up hint,并且hint的值是正确的。
检查你的Flink版本是否支持look up hint。Flink CDC的look up hint是在Flink 1.13版本中引入的,如果你使用的是更早的版本,可能不支持这个功能。
检查你的Flink配置。确保你的Flink配置中包含了look up hint的相关设置。例如,你需要在flink-conf.yaml
文件中添加以下配置:
table.execution.arrow.max-records-per-batch: 1000
table.execution.arrow.max-records-per-stream: 1000
table.execution.arrow.max-records-per-user-buffer: 1000
table.execution.arrow.min-batch-size: 0
table.execution.arrow.min-num-rows-for-batch: 0
table.execution.arrow.min-partition-size: 0
table.execution.arrow.partition-size: 1048576
table.execution.arrow.preferred-buffer-size: 134217728
table.execution.arrow.row-based-output-format: true
table.execution.arrow.use-memory-mapped-buffers: false
table.execution.arrow.use-thread-local-buffers: false
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。