在flink中如何设置Joinstream的set parallelism

Question

当使用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的并行度？

Answer 1

你的数据流程序看起来很奇怪，你有多余的keyby，这可能会让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());