Flink这是啥问题呀？

当你试图将Flink CDC的变更数据流转换为Insert-Only记录时，如果遇到了"datastream api record contains: Delete"错误，那么这表示你的数据流中包含了一些删除操作记录，而Insert-Only模式只支持插入操作记录，无法处理删除操作记录。
要解决这个问题，你可以选择在数据流转换之前使用split方法将包含删除操作的记录分离开来，并将其传入另一个单独的数据流进行处理，而原始的数据流则保持Insert-Only状态继续进行处理。另外，在进行数据流转换之前，还可以使用filter方法来过滤掉包含删除操作的记录，以便更好地控制数据流的流向。

这个错误消息表示Flink在处理MySQL CDC数据时遇到了问题。"conversion expects insert-only records"表示Flink期望只处理插入（insert）操作，而不处理删除（delete）操作。然而，它却发现数据流（datastream）API的记录包含了删除操作。

这可能是由于你在执行Flink任务时，MySQL的数据发生了变化，例如进行了删除操作。这导致Flink无法正确处理这些变化，因此出现了错误。

解决这个问题的方法之一是确保MySQL在执行Flink任务期间不会进行任何可能影响数据流的修改操作，例如删除操作。另一种方法是更新Flink任务的配置，使其能够正确处理包含删除操作的记录。

只能插入 不能删除。此回答整理自钉群“实时计算Flink产品交流群”