FROM_UNIXTIME接收的是秒的时间戳，你的maxwell_ts看起来是微秒吧，应该/1000000吧
macia kk <[email protected]> 于2020年6月7日周日 下午6:15写道： > 打印出来是这样的 > > "maxwell_ts":1591518126072000,"ts_watermark":"52403-03-16 00:21:12" > > macia kk <[email protected]> 于2020年6月7日周日 下午5:53写道： > >> 再次感谢，成功了，这个问题困扰我两周了。还有个问题，能麻烦帮我看下嘛 >> >> 如上，这里定义的 ts_watermark, 想用他们做 watermakr，但是他的返回结果是 null, 我的 maxwell_ts 是 >> millseconds，我看了函数的使用方法，没想到哪里有问题 >> >> val bsSettings = >> EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build() >> val bsTableEnv = StreamTableEnvironment.create(env, bsSettings) val >> sourceTable = """CREATE TABLE my_kafak_source ( | `table` varchar, | >> `database` varchar, | `data` row < transaction_id varchar, | user_id int, | >> amount int, | >, | maxwell_ts bigint, | ts_watermark as >> TO_TIMESTAMP(FROM_UNIXTIME(maxwell_ts/1000)) |) WITH ( |)""".stripMargin >> >> Leonard Xu <[email protected]> 于2020年6月7日周日 下午5:51写道： >> >>> Hi， >>> 1.10确实有这个bug, >>> 这个问题在1.10.1中已经修复了，你可以使用升级到1.10.1，Benchao之前修了一个计算列相关的，我刚刚看不使用计算列也会有这问题，应该是在[1]中 >>> jark wu 修复的。 >>> >>> Best， >>> Leonard Xu >>> [1] https://issues.apache.org/jira/browse/FLINK-16526 < >>> https://issues.apache.org/jira/browse/FLINK-16526> >>> >>> > 在 2020年6月7日，15:32，macia kk <[email protected]> 写道： >>> > >>> > 各位大佬， >>> > >>> > 我的数据源 json 里有 database, table 字段，想解析出来，是保留关键字，我加了反引号，但是还是报错，这是为什么呢 >>> > >>> > val bsSettings = >>> > >>> EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build() >>> > val bsTableEnv = StreamTableEnvironment.create(env, bsSettings) >>> > val sourceTable = """CREATE TABLE my_kafak_source ( >>> > | `table` varchar, >>> > | `database` varchar, >>> > | `data` row < transaction_id varchar, >>> > | user_id int, >>> > | amount int, >>> > | >, >>> > | maxwell_ts bigint, >>> > | ts_watermark as >>> > TO_TIMESTAMP(FROM_UNIXTIME(maxwell_ts/1000)) >>> > |) WITH ( >>> > |)""".stripMargin >>> > >>> > error >>> > >>> > The program finished with the following exception: >>> > >>> > org.apache.flink.client.program.ProgramInvocationException: The main >>> > method caused an error: SQL parse failed. Encountered "table" at line >>> > 1, column 8. >>> > Was expecting one of: >>> > "ABS" ... >>> > "ALL" ... >>> > "ARRAY" ... >>> > "AVG" ... >>> > "CARDINALITY" ... >>> > "CASE" ... >>> > "CAST" ... >>> > "CEIL" ... >>> >>> -- Best, Benchao Li
