Re: Table api son schema

[Benchao Li]

看起来你这个case直接用SQL是可以搞定的。我对table api不太了解，你可以尝试下直接用SQL的DDL~

Zhao,Yi(SEC) <zhaoy...@baidu.com> 于2020年8月11日周二 下午3:40写道：

>
>
>
>
> 如上图，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，就不是动态扩展字段了。
>


-- 

Best,
Benchao Li