if it’s closed, it usually means the writer is closed or maybe the
> operator is closed.
>
>
> > If processElement received a message but consider it as discard and
> does not call collect(), will this block checkpoint's barrier until next
> element was sent by collect() ?
n the collector collect() anymore data?
2. If processElement received a message but consider it as discard and does
not call collect(), will this block checkpoint's barrier until next element
was sent by collect() ?
--
Best Wishes,
Shuwen Zhou
anism to
> achieve fault tolerance and transparent for users. On the other hand,
> savepoint in Flink behaves more like a user control behavior, can savepoint
> not satisfy your demands for crontab?
>
>
>
> Best
>
> Yun Tang
>
>
>
> *From: *Congxian Qiu
>
>
> Best,
>
> Jiayi Liao
>
>
> At 2019-11-21 10:20:47, "shuwen zhou" wrote:
> >Hi Community,
> >I would like to know if there is a existing function to support cron style
> >checkpoint?
> >The case is, our data traffic is huge on HH:30 for
point is already in progress when
minutes is 15 or 45, there would be a config value to trigger a new
checkpoint or pass.
--
Best Wishes,
Shuwen Zhou <http://www.linkedin.com/pub/shuwen-zhou/57/55b/599/>
Forward to user group again since mail server was rejecting for last time
-- Forwarded message -
From: shuwen zhou
Date: Wed, 13 Nov 2019 at 13:33
Subject: Re: RocksDB state on HDFS seems not being cleanned up
To: Yun Tang
Cc: user
Hi Yun,
After my investigation, I found out
