You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by LakeShen <sh...@gmail.com> on 2021/02/25 04:09:14 UTC
Re: 关于flinksql 与维表mysql的关联问题
Hi ,
延迟维表关联这个特性我觉得还是一个比较通用的特性,目前我们考虑借助 Timer 来实现的,社区如果有这个功能的话,我觉得对于 Flink
使用方会有很大帮助的。
我看社区有这样的一个 JIRA 再跟踪了[1],我会持续关注。
[1] https://issues.apache.org/jira/browse/FLINK-19063
Best,
LakeShen
小屁孩 <93...@qq.com> 于2020年6月8日周一 上午9:28写道:
> hi,目前我就是这样做的 数据在启动时会有数据先后到来的问题
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "Px New"<15701181132mr.liu@gmail.com>;
> 发送时间: 2020年6月7日(星期天) 晚上7:02
> 收件人: "user-zh"<user-zh@flink.apache.org>;
>
> 主题: Re: 关于flinksql 与维表mysql的关联问题
>
>
>
> 好的 我可以理解为是: 通过env.addsouce创建一个广播流。下游connect后 在process方法中操作?
>
> 1048262223 <1048262223@qq.com>于2020年6月7日 周日下午3:57写道:
>
> > Hi
> >
> >
> > 可以使用open + broadcast的方式解决~
> >
> >
> > Best,
> > Yichao Yang
> >
> >
> >
> >
> >
> > ------------------&nbsp;原始邮件&nbsp;------------------
> > 发件人:&nbsp;"Px New"<15701181132mr.liu@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 <greemqqran@163.com&gt; 于2020年6月4日周四 下午5:22写道:
> >
> > &gt; 放到open 方法里面可以吗?
> > &gt; 在 2020-06-04 14:15:05,"小屁孩" <932460849@qq.com&gt; 写道:
> > &gt; &gt;dear:&amp;nbsp; &amp;nbsp;
> 我有个问题想请教下,关于flinksql与mysql维表关联
> > 关于mysql更新的问题
> > &gt;
> >
> 有没有好的方法?我现在使用的广播mysql但是有个问题,广播mysql时我的流数据已经到了但是mysql的数据还没有到导致我现在数据会再启动的时候丢失一部分数据
> > &gt;