部分代碼如下:

@Override
public Watermark getCurrentWatermark() {
? ? currentWaterMark = currentTimeStamp - maxDelayAllowed;
? ? return new Watermark(currentWaterMark);
}

intellij出現了這么個問題:

'getCurrentWatermark()' in 'Anonymous class derived from org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks' clashes with 'getCurrentWatermark()' in 'org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks'; attempting to use incompatible return type

解決方案如下:

import org.apache.flink.streaming.api.watermark.Watermark;

改成：

import org.apache.flink.api.common.eventtime.Watermark;

?

總結

以上是生活随笔為你收集整理的‘getCurrentWatermark()‘ in ‘Anonymous class derived from xxx的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。