protected void beAwareOfRecovery() {
        isWatermarkExceeded = false;
    }
Receive the recovery status and react to it.
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/watermark/WatermarkListener.java