Table api son schema

Tue, 11 Aug 2020 00:40:10 -0700 

[cid:image001.png@01D66FF5.A3F680C0]


如上图，field api被标注过期。替换写法被注释掉，使用注视掉的写法会报错如下。

Exception in thread "main" org.apache.flink.table.api.TableException: A raw 
type backed by type information has no serializable string representation. It 
needs to be resolved into a proper raw type.
       at 
org.apache.flink.table.types.logical.TypeInformationRawType.asSerializableString(TypeInformationRawType.java:97)
       at org.apache.flink.table.descriptors.Schema.field(Schema.java:88)
       at jobs.IpGapUserFt2.main(IpGapUserFt2.java:83)

不清楚有啥解决方法吗？


其次，我这边鼓捣了半天，发现使用json schema貌似也没办法实现整个表的动态结构。
我业务中json实际如下：
{
“d”:{
  “key”: value
    …. … .  .. ..// 此处key动态扩展
}
}
我大概想法是d作为一个field，类型是map（但好像不支持map？必须用row）。用row呢，又必须指定其所有field，就不是动态扩展字段了。

回复