Re: 关于flinksql 与维表mysql的关联问题

[Px New]

好的 我可以理解为是： 通过env.addsouce创建一个广播流。下游connect后 在process方法中操作？

1048262223 <1048262...@qq.com>于2020年6月7日 周日下午3:57写道：

> Hi
>
>
> 可以使用open + broadcast的方式解决~
>
>
> Best,
> Yichao Yang
>
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:&nbsp;"Px New"<15701181132mr....@gmail.com&gt;;
> 发送时间:&nbsp;2020年6月6日(星期六) 上午9:50
> 收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
>
> 主题:&nbsp;Re: 关于flinksql 与维表mysql的关联问题
>
>
>
> Hi ,我有一个相关操作的一疑问.
> 疑问: 如果我放在open 中的规则 有可能发生改变,需要重新更新的话呢?
>
> Michael Ran <greemqq...@163.com&gt; 于2020年6月4日周四 下午5:22写道：
>
> &gt; 放到open 方法里面可以吗？
> &gt; 在 2020-06-04 14:15:05，"小屁孩" <932460...@qq.com&gt; 写道：
> &gt; &gt;dear：&amp;nbsp; &amp;nbsp; 我有个问题想请教下,关于flinksql与mysql维表关联
> 关于mysql更新的问题
> &gt;
> 有没有好的方法？我现在使用的广播mysql但是有个问题，广播mysql时我的流数据已经到了但是mysql的数据还没有到导致我现在数据会再启动的时候丢失一部分数据
> &gt;