Hi All,

there is a recent published article in the flink official website for
running beam on top of flink
https://flink.apache.org/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html

In the article:

   - You get additional features like side inputs and cross-language
   pipelines that are not supported natively in Flink but only supported when
   using Beam with Flink

Ultimately, Beam pipeline will be translated into Flink job. So does beam's
side input translates into Flink Broadcast stream?

If I look at org.apache.beam.runners.flink.FlinkStreamingTransformTranslators,
it looks like converting the the side input into broadcast stream, then why
it says Flink does not support it natively?

Thanks a lot!
Eleanore

回复