删除流没有被识别到， 后面加了一个参数 暂时解决。这个是Flink的bug吗？

在Flink CDC（Change Data Capture）的使用过程中，如果删除流没有被识别到，这可能是由于某些特定的问题或限制导致的，而不一定是Flink的bug。

以下是一些可能导致删除流未被识别的原因以及解决方法：

1. 网络问题或其他错误：可能由于网络问题或其他错误，Flink CDC没有正确消费对应的删除事件（delete change log event）。在这种情况下，检查网络连接和作业状态，确保CDC作业能够正常运行。
2. 配置问题：例如，在使用MySQL CDC时，如果server-time-zone参数没有和MySQL服务器时区一致，可能会导致解析timestamp字段时出现问题。确保所有相关的配置参数都正确设置。
3. 版本兼容性问题：在某些情况下，特定版本的flink-cdc-connectors可能存在已知的问题。升级到最新版本的connector jar包可能会解决这些问题。
4. 数据库特定行为：不同的数据库系统可能在处理CDC时有不同的行为。例如，PostgreSQL在进行更新或删除操作时，可能只能获取到设置为表中主键的值，其余字段为默认值。了解数据库的具体行为并采取相应的措施是必要的。

在Flink CDC（Change Data Capture）的使用中，如果您遇到了删除流没有被识这不一定是Flink的bug。通常这种情况可能是由于网络问题或其他错误导致Flink CDC作业未能正常消费删除事件。

解决这类问题的方法有以下几种：

• 检查网络和作业状态：确保Flink CDC作业正常运行，并且没有网络中断或其它故障影响数据的传输。
• 使用DELETE语句：在Flink SQL中直接使用DELETE语句从结果表中删除数据。例如，如果源表中的数据已被标记为删除（比如通过data_deleted字段），则可以使用相应的SQL命令来同步删除结果表中的数据。
• **使用CREATE

不是产品 bug，和您的代码相关【sink 有非确定性函数字段now()，影响了 upsert materialize 节点，后续会增加相应文档说明】。Flink 引擎侧VVR 6.0.7 和 8.x 版本在上线前都会给用户提示的~
此回答整理自钉群“实时计算Flink产品交流群”