DataStreamV2 API: Looking for join with watermark example

[Gunnar Morling]

Hey all,

Is there an example which shows the usage of watermarks with joins in the
DS V2 API? Specifically, I'd like to propagate the minimum watermark of the
two joined streams. Here's my watermark declaration:

    public static final LongWatermarkDeclaration WATERMARK_DECLARATION =
WatermarkDeclarations
        .newBuilder("MY_CUSTOM_WATERMARK_IDENTIFIER")
        .typeLong()
        .combineFunctionMin()
        .combineWaitForAllChannels(true)
        .build();

I'm observing though that all watermarks from either side are propagated
downstream, also if there's a lower watermark on the other side. Does this
ring a bell for anyone?

Thanks a lot,

--Gunnar