> 我删掉重建了一下kafka topic之后,结果就正常了。
这种可能是kafka topic里有脏数据,解析的时间戳不对,导致窗口没触发
>
>
>
>
> 在 2020-06-08 12:05:17,"xu yihan" 写道:
>
> 大家好,
>
>
> 我遇到一个奇怪的问题,通过计算列提取出某一字段。定义为row_time的watermark,
> 如下面原始字段为message,从中提取13位unix-timestamp,转成timestamp(3)再定义为watermark。
>
>
> 执行窗口计算不报错,但是无输出结果。
>
>
>
大家好,
我遇到一个奇怪的问题,通过计算列提取出某一字段。定义为row_time的watermark,
如下面原始字段为message,从中提取13位unix-timestamp,转成timestamp(3)再定义为watermark。
执行窗口计算不报错,但是无输出结果。
数据源是kafka,各partition内数据均匀。
建表语句类似下面(单位机器不能联外网,下面的语句是我手打的,可能有typo请见谅)
create table kafka_source(
message Varchar,
ts as