Модульное тестирование потоков Flink с несколькими потоками событий

Question

У меня есть 2 DataStream s, которые я подключаю и передаю в функцию CoFlatMap.Мне нужно иметь возможность тестировать генерацию сообщений на двух разных DataStream с, но координировать, когда сообщения приходят.Как можно поступить так во Флинке?

Answer 1

Ознакомьтесь с официальным руководством по тестированию устройства .Проверьте особенно последние параграфы относительно использования TestHarness.В вашем случае кажется, что вы должны использовать TwoInputStreamOperatorTestHarness .Вы можете найти пример, как использовать его в CoProcessOperatorTest

Answer 2

Я закончил с: https://github.com/ottogroup/flink-spector/

Документация может использовать небольшое обновление, но в целом это работает очень хорошо.Вот запись pom.xml:

    <dependency>
        <groupId>io.flinkspector</groupId>
        <artifactId>flinkspector-datastream_2.11</artifactId>
        <version>0.8.3</version>
        <scope>test</scope>
    </dependency>