Actually, that code has been around before @zhijiangW last touched it, but old and new do not actually verify the intended behaviour, i.e. "check that there was a call `abortCheckpointOnBarrier(3L, InputEndOfStreamException)`".
If you look at the JavaDocs of `any`, it also reveals why: > Any kind object, not necessary of the given class. > The class argument is provided only to avoid casting. [ Full content available at: https://github.com/apache/flink/pull/6634 ] This message was relayed via gitbox.apache.org for [email protected]
