Flink SQL想试一下CEP这个功能,我读的时候mysql 的表 开启了binlog,但是CEP不支持更新 要加这个数据源变成只追加 这个要如何修改啊?
报错:Match Recognize doesn't support consuming update and delete changes which is produced by node TableSourceScan(table=[[lj-orange, orange, chargeorder]], fields=[Id, PatientId, TotalPrice, RecordCreatedTime])
要将MySQL表从更新模式更改为只追加模式,您需要执行以下步骤:
停止MySQL的binlog功能。可以通过修改MySQL配置文件(my.cnf或my.ini)来实现。在[mysqld]部分添加以下行:
skip-log-bin
然后重启MySQL服务。
将MySQL表更改为只追加模式。可以使用以下SQL命令:
ALTER TABLE your_table_name ROW_FORMAT=FIELDS_TERMINATED_BY '\t' LINES_TERMINATED_BY '
' ENGINE=InnoDB;
将your_table_name
替换为您要更改的表名。这将把表的存储引擎更改为InnoDB,并设置字段和行的分隔符。
重新配置Flink SQL以使用新的数据源。您需要将数据源类型更改为适合只追加模式的类型,例如Kafka、RabbitMQ等。然后,根据新数据源的配置,修改Flink SQL查询以适应新的数据格式。
完成上述步骤后,您的Flink SQL应该可以正常使用CEP功能了。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。