apache-flink - Flink SQL 中 Maps 的使用

Question

如果您注册一个表并且其中一个字段是地图（extra在这种情况下为“），则以下语句可以正常工作：

SELECT f1, f2 FROM customers WHERE extra['sportPrefs'] = 'Football';

现在尝试引用映射中不存在的键。

SELECT f1, f2 FROM customers WHERE extra['moviePrefs'] = 'Action';

您将获得 NPE 并且作业退出。如果有一种方法可以检查映射中是否存在特定键，那就没问题了。不幸的是，我还没有找到方法。检查IS NOT NULL不起作用。没有这个 Flink SQL 中的特征图是非常无用的。我错过了什么？谢谢！

Answer 1

您所描述的是此处描述的错误。

它将在下个月发布的下一个 Flink 版本 1.5.0 中修复。