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!

Reply via email to