@Override
    final void requestSubpartitions() {
        throw new UnsupportedOperationException(
                "RecoveredInputChannel should never request partition.");
    }
@Test
    void testRequestPartitionsImpossible() {
        assertThatThrownBy(() -> buildChannel().requestSubpartitions())
                .isInstanceOf(UnsupportedOperationException.class);
    }