[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17560796#comment-17560796
]
YeAble commented on FLINK-28033:
--------------------------------
hi [~Weijie Guo] , i find this problem when in `over window` always has some
date don't output . so i thinked in this case : only one channel's watermark is
advance and another channel's watermark don't change, this function's result
`newMinWatermark` is not new min watermark ,that is the last min watermark ,
and changed channel's watermark is not emit always.
> find and output new min watermark mybe wrong when in multichannel
> -----------------------------------------------------------------
>
> Key: FLINK-28033
> URL: https://issues.apache.org/jira/browse/FLINK-28033
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Task
> Reporter: YeAble
> Priority: Major
>
> File: StatusWatermarkValve.java
> Method: findAndOutputNewMinWatermarkAcrossAlignedChannels
> {code:java}
> //代码占位符
> long newMinWatermark = Long.MAX_VALUE;
> boolean hasAlignedChannels = false;
> // determine new overall watermark by considering only watermark-aligned
> channels across all
> // channels
> for (InputChannelStatus channelStatus : channelStatuses) {
> if (channelStatus.isWatermarkAligned) {
> hasAlignedChannels = true;
> newMinWatermark = Math.min(channelStatus.watermark, newMinWatermark);
> }
> }
> // we acknowledge and output the new overall watermark if it really is
> aggregated
> // from some remaining aligned channel, and is also larger than the last
> output watermark
> if (hasAlignedChannels && newMinWatermark > lastOutputWatermark) {
> lastOutputWatermark = newMinWatermark;
> output.emitWatermark(new Watermark(lastOutputWatermark));
> } {code}
> channelStatus's initalized watermark is Long.MIN_VALUE. when one
> channelStatus's watermark is changed,but other channelStatus's is not
> changed, the newMinWatermark is always Long.MIN_VALUE and output not
> emitwatermark。
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
