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

使用 flink 1.11 的 tableEnv 的 createTemporaryTable 取注册表，指定 createTemporaryTable 为事件时间，程序包 Field null does not exist 错误，是我用法有问题？ 看了下 https://issues.apache.org/jira/browse/FLINK-16160 这个 issue 是解决的这个问题吗？ tableEnv.connect(kafka) .withSchema(

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

使用 flink 1.11 的 tableEnv 的 createTemporaryTable 取注册表，指定 createTemporaryTable 为事件时间，程序包 Field null does not exist 错误，是我用法有问题？ 看了下 https://issues.apache.org/jira/browse/FLINK-16160 这个 issue 是解决的这个问题吗？ tableEnv.connect(kafka) .withSchema(

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

能贴下完整的异常栈么？ Btw，TableEnvironment上的 connect API 目前不建议使用，有许多已知的问题和缺失的 feature，建议用 executeSql(ddl) 来替代。 社区计划在 1.12 中系统地重构和修复 connect API 。 Best, Jark On Mon, 13 Jul 2020 at 17:24, Hito Zhu wrote: > 使用 flink 1.11 的 tableEnv 的 createTemporaryTable 取注册表，指定 > createTemporaryTable > 为事件时间，程序包 Field nu

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

Hi Jark 异常信息如下： Exception in thread "main" org.apache.flink.table.api.ValidationException: Field null does not exist at org.apache.flink.table.sources.tsextractors.TimestampExtractorUtils.lambda$mapToResolvedField$4(TimestampExtractorUtils.java:85) at java.util.OptionalInt.orElseThr

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

你的源码中 new Schema().field("searchTime",DataTypes.TIMESTAMP()).rowtime(rowtime); 里面的 rowtime 的定义能贴下吗？ On Mon, 13 Jul 2020 at 20:53, Hito Zhu wrote: > Hi Jark 异常信息如下： > Exception in thread "main" org.apache.flink.table.api.ValidationException: > Field null does not exist > at > > org.apache

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

rowtime 定义如下，我发现 SchemaValidator#deriveFieldMapping 方法给移除了。 Rowtime rowtime = new Rowtime() .timestampsFromField("searchTime") .watermarksPeriodicBounded(5 * 1000); -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

这可能是 connect API 的某个 bug 吧。 建议先用 DDL 。 Best, Jark On Tue, 14 Jul 2020 at 08:54, Hito Zhu wrote: > rowtime 定义如下，我发现 SchemaValidator#deriveFieldMapping 方法给移除了。 > Rowtime rowtime = new Rowtime() > .timestampsFromField("searchTime") > .watermarksPeriodicBounded(5 *

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

好吧，感谢回答 -- Sent from: http://apache-flink.147419.n8.nabble.com/