下游数据做好幂等操作,就不怕重复操作了。。
在 2021-02-04 11:26:56,"op" <520075...@qq.com> 写道:
>重启可能会导致数据重发,想加个告警
>
>
>
>
>------------------ 原始邮件 ------------------
>发件人:
> "user-zh"
>
><wander4...@gmail.com>;
>发送时间: 2021年2月4日(星期四) 中午11:11
>收件人: "user-zh"<user-zh@flink.apache.org>;
>
>主题: Re: 如何在程序里面判断作业是否是重启了
>
>
>
>业务上的需求是什么?
>
>Best,
>tison.
>
>
>op <520075...@qq.com> 于2021年2月4日周四 上午11:04写道:
>
>> 大家好:
>> &nbsp;
>>
>&nbsp;我在程序里通过RestartStrategies设置了重启策略,现在想在算子里面判断是否是触发了Restart,请问有哪些方法能实现呢?