Hi Peihui, 如果消费的 Kafka json 中,json 比较复杂的话,比如存在嵌套,就像下面的格式:
{ "a":"b", "c":{ "d":"e", "g":"f" } }, 那么在 kafka table source 可以使用 row 来定义: create table xxx ( a varchar, c row<d varchar , g varchar> ) 如果 还存在嵌套,可以继续再使用 Row 来定义。 Best, LakeShen Peihui He <peihu...@gmail.com> 于2020年7月10日周五 上午9:12写道: > Hello: > > 在用flink sql从kafka消费数据时,有些json比较复杂,想直接定义为object,在后续通过udf转为string。 > > 有什么办法不?我在建表的时候有提示过json_object 类型,但是用了又提示其他类型。 > > > Best wishes. >