8得票4回答
使用Apache Flink SQL从Kafka消息中获取嵌套字段

我正在尝试使用Apache Flink 1.11创建一个源表,以便可以访问JSON消息中的嵌套属性。我可以获取根属性的值,但不确定如何访问嵌套对象。 文档建议应该使用MAP类型,但是当我设置它时,出现以下错误: : java.lang.UnsupportedOperationExcepti...