You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by yidan zhao <hi...@gmail.com> on 2022/02/21 02:42:22 UTC

关于timestamp在eventTime和processTIme、以及各种不同API情况下的不同实现。

如题，目前看很多实现不是很清楚为啥这么设计。
比如，对于window来说，不论是et还是pt情况，emit的时候都是window.maxTs。

对于process部分，因为不支持定时器，因此只存在processElement输出，采用输入ele的ts。
对于keyedProcess部分，processElement部分同上；onEventTime则采用输入ele的ts，但onProcessTime则删除了ele的ts，这是为啥？