@Override
    public void forEachEventTimeTimer(BiConsumerWithException<N, Long, Exception> consumer) {
        throw new UnsupportedOperationException(
                "The BatchExecutionInternalTimeService should not be used in State Processor API.");
    }
@Test
    void testForEachEventTimeTimerUnsupported() {
        BatchExecutionInternalTimeService<Object, Object> timeService =
                new BatchExecutionInternalTimeService<>(
                        new TestProcessingTimeService(),
                        LambdaTrigger.eventTimeTrigger(timer -> {}));

        assertThatThrownBy(
                        () ->
                                timeService.forEachEventTimeTimer(
                                        (o, aLong) ->
                                                fail(
                                                        "The forEachEventTimeTimer() should not be supported")))
                .isInstanceOf(UnsupportedOperationException.class)
                .hasMessageContaining(
                        "The BatchExecutionInternalTimeService should not be used in State Processor API");
    }