flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Congxian Qiu <qcx978132...@gmail.com>
Subject Re: How do I initialize the window state on first run?
Date Fri, 12 Oct 2018 12:14:32 GMT
IIUC, we can't  initialize state at first run,  maybe you could store the
aggregated data in another place other than use flink's state, then use
flink to aggregate the data realtime.

bupt_ljy <bupt_ljy@163.com> 于2018年10月12日周五 下午3:33写道:

> Hi, vivo,
>
>     My Flink program is to aggregate the data of a whole day, assume we
> start this program on 6:00 am, the default state in the window should be
> the aggregated result of 0:00 am to 6:00 am.
>
>  Original Message
> *Sender:* vino yang<yanghua1127@gmail.com>
> *Recipient:* bupt_ljy<bupt_ljy@163.com>
> *Cc:* user<user@flink.apache.org>
> *Date:* Friday, Oct 12, 2018 15:13
> *Subject:* Re: How do I initialize the window state on first run?
>
> Hi Jiayi,
>
> If you don't mind, I would like to ask you what kind of situation do you
> have in this situation?
>
> Thanks, vino.
>
> bupt_ljy <bupt_ljy@163.com> 于2018年10月12日周五 下午1:59写道:
>
>> Hi,
>>
>>    I’m going to run a new Flink program with some initialized window
>> states.
>>
>>    I can’t see there is an official way to do this, right? I’ve tried the
>> bravo project, but it doesn’t support FsStateBackend and it costs too much
>> work if we add a new StateBackend in it.
>>
>>    Any good ideas about this?
>>
>>
>>
>>
>> Jiayi Liao,Best
>>
>>
>>
>

-- 
Blog:http://www.klion26.com
GTalk:qcx978132955
一切随心

Mime
View raw message