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

有人知道这个bug吗 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

试了 1.12.2，还是一样问题。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

但是看情况好像是只有在：DataStream发生Keyby或者 setParallelism的时候才会发生 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

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

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

你好， 你的flink版本是多少？ 之前有个bug是Table转datastream 会丢rowtime问题，看起来是这个问题。 我在[1]里修复了，你可以升级对应的版本试下。 祝好， Leonard [1]https://issues.apache.org/jira/browse/FLINK-21013 > 在 2021年3月10日，14:34，HunterXHunter <1356469...@qq.com> 写道： > > 再试了一下： > 修改并行度也不行 >

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

再试了一下： 修改并行度也不行 .setParallelism(9) -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

经过再一次验证： 即使我做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(Typ

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

1：当DataStream是由 一个table 经过 group by rowtime 转换过来的就无法触发窗口 例如： tableEnv.createTemporaryView("test3", tableEnv.sqlQuery("select msg,rowtime from test group by msg,rowtime")); // 获得 DataStream，并定义wtm生成 SingleOutputStreamOperator r = tableEnv.toRetractStream(tableEnv.from("test3"), Row.class) .filter