Hi Averell,
This seems to be the bug that you encountered:
https://issues.apache.org/jira/browse/FLINK-11046.
Cheers,
Gordon
On Sat, Feb 9, 2019 at 3:27 PM Averell wrote:
> Hello,
>
> I am trying to follow this Flink guide [1] to handle errors in
> ElasticSearchSink by re-adding the failed mes
Hi, Aggarwal.
Your strategy to limit the total state is right. And there did not
have an API will give user the hint about cleared/expired state.
I think you can associate every key with two states: one as the
ttl-state, one as the “seen”-state(ValeState)—the “seen”-state
will tell you
