数据先后到来的问题
>
>
>
>
> -- 原始邮件 --
> 发件人: "Px New"<15701181132mr@gmail.com>;
> 发送时间: 2020年6月7日(星期天) 晚上7:02
> 收件人: "user-zh"
> 主题: Re: 关于flinksql 与维表mysql的关联问题
>
>
>
> 好的 我可以理解为是： 通过env.addsouce创建一个广播流。下游connect后 在process方法中操作？
>
Hi
是的。
Best,
Yichao Yang
发自我的iPhone
-- 原始邮件 --
发件人: Px New <15701181132mr@gmail.com>
发送时间: 2020年6月7日 19:03
收件人: user-zh
;Px New"<15701181132mr@gmail.com>;
> 发送时间: 2020年6月6日(星期六) 上午9:50
> 收件人: "user-zh"
> 主题: Re: 关于flinksql 与维表mysql的关联问题
>
>
>
> Hi ,我有一个相关操作的一疑问.
> 疑问: 如果我放在open 中的规则 有可能发生改变,需要重新更新的话呢?
>
> Michael Ran
> > 放到open 方法里面可以吗？
> > 在 2020-06-
Hi ,我有一个相关操作的一疑问.
疑问: 如果我放在open 中的规则 有可能发生改变,需要重新更新的话呢?
Michael Ran 于2020年6月4日周四 下午5:22写道：
> 放到open 方法里面可以吗？
> 在 2020-06-04 14:15:05，"小屁孩" <932460...@qq.com> 写道：
> >dear： 我有个问题想请教下,关于flinksql与mysql维表关联 关于mysql更新的问题
> 有没有好的方法？我现在使用的广播mysql但是有个问题，广播mysql时我的流数据已经到了但是mysql的数据还没有到导致我现在数据会再启动的时候丢失一
ctx.collect(map);
> map.clear();
> Thread.sleep(2000 * 60);
> }
>
>
> }
>
>
>
>
> @Override
> public void cancel() {
> try {
> super.close();
> if (connection != null) {
> conne
