Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/4980#discussion_r149947094 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java --- @@ -254,12 +300,10 @@ else if (this.error == null) { @Override public void triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetrics checkpointMetrics) throws Exception { - throw new UnsupportedOperationException("Should not be called"); --- End diff -- Why was this removed?
---