合理做法是open中把最初一波配置流加载好,然后广播流只是增量部分数据。

Yuepeng Pan <[email protected]> 于2021年11月8日周一 上午10:11写道:

>
>
>
> Hi, 俊超.
> 如果你指的是数据流必须在接受到一个或者多个ddl数据流才能够继续解析的话,那么你可以在ddl流到达算子之前,将数据流存入liststate,当接收到ddl类型的数据流元素后,先解析或处理
> liststate中的数据,而后继续处理当前与后续的来自数据流的元素。
>       也可以使用上述方式达到 ‘使用广播流的方式来提前加载mysql表结构的变化’  的逻辑效果。
>
>        [1].
> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/ops/state/state_backends/
>        [2].
> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/fault-tolerance/broadcast_state/
>
>
> 祝好。
>
>
> Best,
> Roc
>
>
>
>
> 在 2021-11-08 09:44:52,"程俊超" <[email protected]> 写道:
>
> >您好,我想使用广播流的方式来提前加载mysql表结构的变化(ddl),但是会遇到广播流没有数据流到达速度快的情况,导致问题。网上说可以使用liststate来解决这种情况,但是具体应该如何使用呢
> >
> >
> >| |
> >程俊超
> >|
> >|
> >邮箱:[email protected]
> >|
> >
> >签名由 网易邮箱大师 定制
>

回复