Hello:
I am a graduate student from ustc. I have a little doubt about flink
programming recently. I hope to get your reply, thank you.
I use the split operator to split a stream into two streams. However, I found
that the parallelism of the two streams can only be set separately, so that
each of the two streams is itself parallel in multiple slots. But my goal is to
get the two streams, one in one slot and the other in another.
Specifically, I split the two streams of the split operator, and the degree of
parallelism is set to 1, respectively, then they are equivalent to running in
the same slot. But my goal is to have them run in two slots separately.
Maybe I should use a keyedStream stream and customize KeySelector?
I hope to hear from you, thank you again.
Best
Xuyangzhong