Flink TestHarness вывод не очищается после сбора - PullRequest
Новая
       20

Flink TestHarness вывод не очищается после сбора

0 голосов
/ 08 ноября 2019

У меня есть следующий тест: 

testHarness.processElement2(new StreamRecord<>(element1));
testHarness.processElement1(new StreamRecord<>(new Tuple2<>(id, element2)));

testHarness.setProcessingTime(1); //let's assume it's the correct time for the timer inside the function
softly.assertThat(testHarness.getOutput()).containsExactly(new StreamRecord<>(expectedResult)); //this one is passed

testHarness.setProcessingTime(2); // setting second timer which will trigger different timer
softly.assertThat(testHarness.getOutput()).containsExactly(new StreamRecord<>(expectedResult2)); //fails cause output has  expectedResult & expectedResult2

Почему TestHarness не очищает свои элементы после вызова getOutput ()? Может ли эта функциональность быть достигнута каким-то образом?

...