Re: flink table api中无法设置子json中的列为rowtime

1. 只支持指定顶层字段作为 rowtime，如果要使用 nested field 作为 rowtime，可以先使用计算列（仅在 DDL 上支持）生成顶层列。 2. Descriptor API 有很多问题，且缺失很多功能，不建议使用，建议使用 DDL。 Descriptor API 将在1.12 版本中重构。 Best, Jark On Thu, 17 Sep 2020 at 10:41, kylin wrote: > flink版本1.7.2 > > flink table api从kafka读取json数据，JsonSchema如下图所示 > 发现rowtime无法从子js

flink table api中无法设置子json中的列为rowtime

flink版本1.7.2 flink table api从kafka读取json数据，JsonSchema如下图所示 发现rowtime无法从子json中的字段指定，麻烦帮忙确认下rowtime是否只能从顶层的字段来指定？ tableEnv.connect( new Kafka() .version("0.10") .topic(topic_in) .property("bootstrap.servers", brokers) .property("group.id", "TableApiT2") .startFromLatest() ).wit