Hi all,
My flink job has dynamic schema of data, so I want to consume a schema kafka
topic and try to broadcast to every operator so that each operator could know
what kind of data it is handling.
For example, the two streams just like this:
OperatorA -> OperatorB -> OperatorC
^ ^ ^
| | |
BroadcastStream
If the broadcast stream does not exist, OperatorA, OperatorB, OperatorC are
chained together in one slot because they have the same parallelism so that it
can gain maximum performance.
And I was wondering that if the broadcast stream exists, will it affect the
performance? Or flink will still chain them together to gain maximum
performance?
Thanks!