Re: flink sql about nested json

HI Timo I have get the nested value by change the Schema definition like this Schema schemaDesc1 = new Schema() .field("str2", Types.STRING) .field("tablestr", Types.STRING).from("table") * .field("obj1", Types.ROW_NAMED(new String[]{"rkey","val","lastTime"}, Types.STRI

Re: flink sql about nested json

杨光 下午3:22 (1分钟前) 发送至 Timo、 user HI Timo I have get the nested value by change the Schema definition like this Schema schemaDesc1 = new Schema() .field("str2", Types.STRING) .field("tablestr", Types.STRING).from("table") * .field("obj1", Types.ROW_NAMED(new String[]{"rk

Re: flink sql about nested json

Hi, Flink SQL JSON format supports nested formats like the schema that you posted. Maybe the renaming with `from()` works not as expected. Did you try it without the `from()` where schema fields are equal to JSON fields? Alternatively, you could also define the schema only and use the `deriv