[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Stream.union doesn't change the parallelism of the new stream?

It seems, at least in Flink 1.3.2, unioning two streams together doesn't change the parallelism, and that the new stream just retains the parallelism of the stream in the first. Does it make sense for the parallelism of the new stream to be set to the max of the two streams parallelism? Do I have to make a manual call for this every time?