请问 flink 能流式读取iceberg upsert primary key 表吗？

不可以，iceberg社区这方面很久没动作了。 有需要考虑下paimon吧 ，此回答整理自钉群“【③群】Apache Flink China社区”

Flink 目前不支持直接流式读取 Iceberg Upsert Primary Key 表。Iceberg Upsert Primary Key 是一种用于支持更新和删除操作的表格式，它需要对数据进行额外的处理才能实现这些操作。

如果你需要在 Flink 中流式读取 Iceberg Upsert Primary Key 表，你可以考虑以下两种方法：

1. 使用 Flink 的 CDC（Change Data Capture）功能：Flink CDC 可以捕获数据库中的变更事件，并将其转换为流式数据。你可以使用 Flink CDC 来捕获 Iceberg Upsert Primary Key 表中的变更事件，并将其转换为流式数据进行处理。

2. 将 Iceberg Upsert Primary Key 表转换为其他支持流式读取的表格式：你可以将 Iceberg Upsert Primary Key 表导出为其他支持流式读取的表格式，例如 Parquet、Avro 或 JSON。然后，你可以使用 Flink 的流式读取功能来读取导出后的表。