Flink 1.15:支持JSON_OBJECT
我有一个Flink表,我想为它编写一个选择查询,该查询将返回基于某些字段的JSON对象。
这是我想做的查询(基于方解石语法:https://calcite.apache.org/docs/reference.html#constructor-功能(:
SELECT
myIdField,
aFloatField,
JSON_OBJECT('aFieldName':aFloatField)
FROM myTable
但是当我尝试将这个查询与Flink一起使用时,我会得到以下错误:
org.apache.flink.table.api.ValidationException: SQL validation failed. No match found for function signature JSON_OBJECT(<null>, , )
这样做的好方法是什么?我在Flink文档中找不到任何关于这方面的信息。
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#json-功能