Re: flink 1.11 createTemporaryTable 指定 rowtime 字段报 Field null does not exist 错误

[Jark Wu]

能贴下完整的异常栈么？

Btw，TableEnvironment上的 connect API 目前不建议使用，有许多已知的问题和缺失的 feature，建议用
executeSql(ddl) 来替代。
社区计划在 1.12 中系统地重构和修复 connect API 。

Best,
Jark

On Mon, 13 Jul 2020 at 17:24, Hito Zhu <qrshi....@gmail.com> wrote:

> 使用 flink 1.11 的 tableEnv 的 createTemporaryTable 取注册表，指定
> createTemporaryTable
> 为事件时间，程序包 Field null does not exist 错误，是我用法有问题？
> 看了下  https://issues.apache.org/jira/browse/FLINK-16160
> <https://issues.apache.org/jira/browse/FLINK-16160>   这个 issue 是解决的这个问题吗？
>
> tableEnv.connect(kafka)
>     .withSchema(
>       new Schema().field("searchTime",
> DataTypes.TIMESTAMP()).rowtime(rowtime);
>     )
>     .withFormat(
>         new Json().failOnMissingField(false)
>     )
>     .createTemporaryTable("tablename");
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>