В чем разница между TestProcessingTimeService и InternalTimeServiceManagerImpl? ⇐ JAVA

[Anonymous]

При модульном тестировании Apache Flink с ProcessFunctionTestHarnesses

Код: Выделить всё

KeyedOneInputStreamOperatorTestHarness testHarness = ProcessFunctionTestHarnesses.forKeyedProcessFunction

TestHarness имеет доступ к 2 классам для получения количества активных таймеров в ключевой функции процесса.

• Код: Выделить всё

  int i = testHarness.getProcessingTimeService().getNumActiveTimers()

• Код: Выделить всё

  int k = testHarness.numProcessingTimeTimers()

Я просмотрел Java-документ TestProcessingTimeService и InternalTimeServiceManager, но описание мало что говорит.
В чем разница между двумя и какой из них следует использовать?
В моей KeyedProcessFunction я устанавливаю, а затем удаляю таймер обработки. Я ожидаю, что в конце моего UT будет 0 активных таймеров обработки. Из приведенного выше фрагмента k передает утверждение о том, что оно равно 0, но i терпит неудачу, поскольку его фактическое значение равно 1.

Подробнее здесь: https://stackoverflow.com/questions/784 ... ervicemana