Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5105#discussion_r156389253 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/RecordWriterTest.java --- @@ -558,4 +565,10 @@ public void read(DataInputView in) throws IOException { return nextChannel; } } + + private class ExpectedException extends RuntimeException { --- End diff -- how about using Flink's `ExpectedTestException` instead?
---