Re: Re: 怎样把 state 定时写到外部存储

Mon, 04 Nov 2019 19:11:34 -0800 

你好，

对你的问题描述有一些疑问

> 每一条消息来都会更改 state 值，如果每一条消息来都写外部存储下游撑不住
> 有没有什么方式可以定期读 state 写到外部存储？

这里是什么意思呢？更改 state 值和写外部系统存储应该是两个独立的事件。state 是 Flink 内部使用的，给外部系统使用的数据一般通过
sink 写出去，和 state 没有直接关系。

从你的描述中，只看到貌似是写 Mysql (是通过 sink 吗？) 扛不住。批量写一下？比如在 sink 中处理一下

如果没理解对你的问题，你可以再详细描述一下

Thanks,
Biao /'bɪ.aʊ/



On Fri, 1 Nov 2019 at 11:21, misaki L <[email protected]> wrote:

> 使用 window 聚合一下批量写呢？
>
> [email protected] <[email protected]> 于2019年11月1日周五
> 上午10:17写道：
>
> > Hi Congxian，
> >
> > 以 sink 的方式写出去最终也要落在某个地方才能供查询使用啊。
> > 我们的 case 是写到 MySQL 中
> >
> >
> >
> > [email protected]
> >
> > Sender: Congxian Qiu
> > Send Time: 2019-11-01 10:10
> > Receiver: user-zh
> > Subject: Re: 怎样把 state 定时写到外部存储
> > 好奇为什么要把 State 定期写到外存呢？是外部系统需要使用这些 State 吗？那为什么不把 State 以 sink 的方式写出去呢？
> >
> > Best,
> > Congxian
> >
> >
> > Jun Zhang <[email protected]> 于2019年10月31日周四 上午10:36写道：
> >
> > > 是否可以注册一个定时器？
> > >
> > >
> > > 你看看这个文章，是否对你有帮助
> > >
> > >
> > > https://mp.weixin.qq.com/s/VUEvvoHoupZMpxWQsEeHEA
> > >      在2019年10月31日 10:16，[email protected]<
> > [email protected]&gt;
> > > 写道：
> > >
> > >
> > > 消息驱动，QPS 很高， 每一条消息来都会更改 state 值，如果每一条消息来都写外部存储下游撑不住。
> > > 有没有什么方式可以定期读 state 写到外部存储？
> > > 我现在用的是 Flink1.7.2 版本。
> > >
> > >
> > >
> > >
> > >
> > > [email protected]
> >
>

回复