时间戳

首页 > 解决方案 > 在flink中如何设置Joinstream的设置并行度

join - 在flink中如何设置Joinstream的设置并行度

问题描述

当使用 joinStream 加入两个流时，我无法设置 joinStream 的并行度，它始终为 1

aStream.assignTimestampsAndWatermarks(new AWatermarks())
    .keyBy(AStream::getKey)
    .join(bStream.assignTimestampsAndWatermarks(new BWatermarks())
    .keyBy(BStream::getKey))
    .where(AStream::getKey).equalTo(BStream::getKey)
    .window(TumblingEventTimeWindows.of(Time.seconds(30))).apply(new Joiner())

在此处输入图像描述

有什么方法可以设置 JoinStream 的并行度

标签： joinapache-flink

解决方案

你的数据流程序看起来很奇怪，你有多余keyby的 s，这可能会混淆 Flink。你能试试吗

    aStream.assignTimestampsAndWatermarks(new AWatermarks())
        .join(bStream.assignTimestampsAndWatermarks(new BWatermarks()))
        .where(AStream::getKey).equalTo(BStream::getKey)
        .window(TumblingEventTimeWindows.of(Time.seconds(30))).apply(new Joiner());

推荐阅读