如果有多个下游操作符，flink会发送重复的记录吗

ff29svar 于 2021-06-21 发布在 Flink

关注(0)|答案(2)|浏览(463)

如果我运行一个示例flink应用程序，如下所示：

DataStream ds;
ds.map(new MapFunction1()).print();
ds.map(new MapFunction2()).print();

flink是否会在内部将ds中的每条记录发送两次给下游操作员（mapfunction1和mapfunction2）？
我知道flink中的数据交换是在taskmanager级别进行的，而不是在操作员级别。

Java apache-flink

来源：https://stackoverflow.com/questions/53549823/does-flink-sends-duplicate-records-if-there-are-multiple-downstream-operator

2条答案

按热度按时间

pjngdqdw1#

是，请尝试：

StreamExecutionEnvironment environment =
            StreamExecutionEnvironment.getExecutionEnvironment();

    DataStream<Long> someIntegers = environment.generateSequence(0, 0);
    someIntegers.map(aLong -> aLong + 1).print();
    someIntegers.map(aLong -> aLong + 2).print();

    environment.execute();

输出：