貌似问题变成这样子
程序流程如下：WM=watermark
source(没有WM)-->转换A-->TableA(没有WM)--->转换B--->TableB(没有WM)>转换C(sql
TUMBLE)-->TableC-->Sink
为了让转换C的Sql能够成功执行，如何在TableB上Assign一个Watermark??
From stevenchen
webchat 38798579
发件人: Chennet Steven
发送时间: Friday, June 21, 2019 1
Flink 1.4.2
执行Sql SELECT Tag, SUM(PowerX) FROM TimeTable GROUP BY TUMBLE(UptMs, INTERVAL
'1' HOUR),Tag
会报异常，但是感觉UptMs列类型是TimeStamp啊？
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Window can only be defined over a time attribute column.
at
org.apache.flink.
