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

Mon, 13 Jul 2020 02:23:07 -0700 

使用 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/

回复