Как использовать класс TestHarness Флинка? - PullRequest
Новая
       36

Как использовать класс TestHarness Флинка?

0 голосов
/ 16 февраля 2019

Мне нужно протестировать функцию CoFlatMap, которая разделяет состояние.После прочтения я пришел к выводу, что должен использовать класс TestHarness для: https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling

Поскольку он не является частью общедоступного API, я не могу понять, как его импортировать без копирования и вставки самого класса.,Я думал, что это может быть в flink-test-utils-junit, но это было не так хорошо.

1 Ответ

0 голосов
/ 16 февраля 2019

Вам нужно будет добавить эти 4 зависимости в ваш проект (или версии 2.12, если вы используете версию scala): 

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-test-utils-junit</artifactId>
        <version>${flink.version}</version>
    </dependency>

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.11</artifactId>
        <version>${flink.version}</version>
        <scope>test</scope>
        <type>test-jar</type>
    </dependency>

    <dependency>
        <groupId>org.mockito</groupId>
        <artifactId>mockito-all</artifactId>
        <version>1.10.19</version>
        <type>jar</type>
        <scope>test</scope>
    </dependency>

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-runtime_2.11</artifactId>
        <version>${flink.version}</version>
        <scope>test</scope>
        <type>test-jar</type>
    </dependency>

Я написал anПример, который вы можете найти на github , может оказаться более легкой отправной точкой.Тестируемое приложение описано в онлайн-обучении Flink .

...