Re: Verifying watermarks in integration test

Hi, I had sorted out how to run the topology in embedded mode. What wasn't clear to me is how I can verify the watermark, but as per following thread that can be done by inserting a process function:

Re: Verifying watermarks in integration test

Hi Xingcan, thanks, this is a good way of testing an individual operator. I had written my own mock code to intercept source context and collect the results, this is a much better approach for operator testing. I wonder how I can verify with an embedded Flink cluster though. Even though my

Re: Verifying watermarks in integration test

Hi Thomas, some test cases in JoinHarnessTest show how to verify the emitted watermarks. Hope this helps. Best, Xingcan > On 21 Feb