如何在Apache IoTDB版本1.3.0的flink sql连接器中启动CDC？

Question

我现在使用的服务器和客户端都是Apache IoTDB 1.3.0版本。我想使用Flink SQL IoTDB Connector中的CDC功能，但是当我完成所有配置设置后，似乎仍然没有启动。我查了官方指南，没有发现任何新内容。我想知道CDC是否需要手动开启，如何开启？

Answer 1

尝试在 Apache IoTDB 的 Cli 工具中执行

flush

。由于开源版本中CDC依赖的管道事件不是实时发送的，所以需要执行flush来触发。如果您需要实时发送管道，可以考虑使用企业版。