请问 Flink CEP 不支持 Flink CDC 吗？直接报错 Match Recognize

Flink CEP 目前确实存在对更新和删除类型变更数据处理的限制，这与您遇到的错误信息“Match Recognize doesn't support consuming update and delete changes which is produced by node TableSourceScan”相符。Flink CEP 的 Match Recognize 语句主要用于流数据上的复杂事件处理，它设计上主要是针对插入（insert）类型的事件流进行模式匹配。

当您的数据源通过 Flink CDC (Change Data Capture) 接入，并且包含更新(update)或删除(delete)操作时，这些变更可能会被当作不支持的操作类型，因为 Flink CEP 的 Match Recognize 处理逻辑尚不直接兼容处理非插入型的数据变更。

解决方案建议

1. 数据预处理：在将数据输入到 Flink CEP 之前，可以使用 Flink 的数据流转换操作（例如 map、filter 等）来过滤或转换 CDC 中的更新和删除事件，将其转换为适合 CEP 模式匹配的插入事件形式。这样虽然不能直接保留原生的更新/删除语义，但能确保数据能够通过 CEP 进行处理。

2. 选择支持更新的Sink：如果您的场景允许，可以选择一个支持写入更新记录的Sink，如 Upsert Kafka，来间接支持这类操作。但这需要您的下游系统或进一步的数据处理流程能够正确解析和应用这些更新操作。

3. 调整数据处理策略：考虑是否可以调整整体的数据处理架构，比如先利用其他工具或方法处理CDC的更新和删除事件，再将处理后的数据送入Flink CEP进行事件模式匹配。

4. 关注社区进展：持续关注 Apache Flink 社区的发展动态，未来版本中可能会增强 Flink CEP 对于 CDC 更新和删除事件的支持能力。

综上所述，当前Flink CEP直接应用于包含更新和删除变更数据的场景存在局限性，需通过上述变通方案来适应此类需求。您可以复制页面截图提供更多信息，我可以进一步帮您分析问题原因。