探索云世界
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 集群和引擎，提高作业开发运维效率。
