Hi Thomas, some test cases in JoinHarnessTest <https://github.com/apache/flink/blob/release-1.4/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala> show how to verify the emitted watermarks.
Hope this helps. Best, Xingcan > On 21 Feb 2018, at 2:09 PM, Thomas Weise <t...@apache.org> wrote: > > Hi, > > I have a streaming integration test with two operators. A source that emits > records and watermarks, and a sink that collects the records. The topology > runs in embedded mode and the results are collected in memory. Now, in > addition to the records, I also want to verify that watermarks have been > emitted. What's the recommended way of doing that? > > Thanks
