Re:Flink Kafka Sink时间戳异常

hi， 这个问题是因为经过窗口算子后StreamRecord中指定的时间时间戳被改成了window.maxTimestamp()，可以查看[1]中WindowOperator或EvictingWindowOperator中的emitWindowContents方法。 如果想要更改时间戳，可以实现一个ProcessFuncton TimestampedCollector collector = (TimestampedCollector) out; collector.setAbsoluteTimestamp( ); collector.collect(value);

Re: 退订

退订请发送邮件到 user-zh-unsubscr...@flink.apache.org Best, Weihua On Tue, Feb 28, 2023 at 12:13 AM zhangjunjie wrote: > 退订 > > >

退订

退订

Re: 【Windowing TVF】 GROUP BY window_start, window_end 没有输出

Hi, 可以详细描述下你的使用 case 吗？用的 SQL 语句是什么样子的 Best, Weihua On Mon, Feb 27, 2023 at 12:51 PM wei_yuze wrote: > 您好！ > > > > > 我在使用Windowing table-valued functions (Windowing TVFs) 的时候，GROUP BY 中一旦加上 > window_start, window_end 就没有输出，但也不报错。请问有哪位大佬知道是什么原因吗？ > > Lucas