Re: BUG ：DataStream 转 Table 后无法 触发窗口计算

Tue, 09 Mar 2021 22:30:49 -0800 

经过再一次验证：
即使我做group by rowtime的操作，
我对datastream做keyby(rowtime) 也有这个问题
例如：
tableEnv.createTemporaryView("test3", tableEnv.sqlQuery("select msg,rowtime
from test "));
SingleOutputStreamOperator r =
tableEnv.toRetractStream(tableEnv.from("test3"), Row.class)
.filter(x -> x.f0)
.keyby(_.f1)
.returns(Types.TUPLE(Types.STRING, Types.LONG))
.assignTimestampsAndWatermarks(
                        WatermarkStrategy.<Tuple2&amp;lt;String,
Long>>forBoundedOutOfOrderness(Duration.ofSeconds(1))
                                .withTimestampAssigner(((element,
recordTimestamp) -> element.f1))
                );

结果也是无法触发窗口



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复