flink-1.11.1 setMinPauseBetweenCheckpoints不生效

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

flink-1.11.1 setMinPauseBetweenCheckpoints不生效

nicygan
dear  all:
    我在checkpoint设置中,设置了

     checkpointConfig.setMinPauseBetweenCheckpoints(180_000L)
     但是好像并没有生效,
     比如id=238的结束时间为17:13:30
     但是id=239的开始时间也是17:13:30
   

    我的理解id=239的开始时间至少应该是17:16:30

    是我对这个参数理解有误吗?


thanks
by nicygan
Reply | Threaded
Open this post in threaded view
|

Re: flink-1.11.1 setMinPauseBetweenCheckpoints不生效

nobleyd
I don't believe what you say...

nicygan <[hidden email]> 于2020年12月24日周四 下午7:25写道:

> dear  all:
>     我在checkpoint设置中,设置了
>
>      checkpointConfig.setMinPauseBetweenCheckpoints(180_000L)
>      但是好像并没有生效,
>      比如id=238的结束时间为17:13:30
>      但是id=239的开始时间也是17:13:30
>
>
>     我的理解id=239的开始时间至少应该是17:16:30
>
>     是我对这个参数理解有误吗?
>
>
> thanks
> by nicygan
>
Reply | Threaded
Open this post in threaded view
|

Re: flink-1.11.1 setMinPauseBetweenCheckpoints不生效

Dian Fu
应该是个已知问题,在1.11.2里已经修复了:https://issues.apache.org/jira/browse/FLINK-18856

> 在 2020年12月24日,下午9:34,赵一旦 <[hidden email]> 写道:
>
> I don't believe what you say...
>
> nicygan <[hidden email]> 于2020年12月24日周四 下午7:25写道:
>
>> dear  all:
>>    我在checkpoint设置中,设置了
>>
>>     checkpointConfig.setMinPauseBetweenCheckpoints(180_000L)
>>     但是好像并没有生效,
>>     比如id=238的结束时间为17:13:30
>>     但是id=239的开始时间也是17:13:30
>>
>>
>>    我的理解id=239的开始时间至少应该是17:16:30
>>
>>    是我对这个参数理解有误吗?
>>
>>
>> thanks
>> by nicygan
>>

Reply | Threaded
Open this post in threaded view
|

Re:Re: flink-1.11.1 setMinPauseBetweenCheckpoints不生效

nicygan
Dian Fu:
      谢谢解惑,我试试换个版本。


thank you
by nicygan

在 2020-12-24 22:44:04,"Dian Fu" <[hidden email]> 写道:

>应该是个已知问题,在1.11.2里已经修复了:https://issues.apache.org/jira/browse/FLINK-18856
>
>> 在 2020年12月24日,下午9:34,赵一旦 <[hidden email]> 写道:
>>
>> I don't believe what you say...
>>
>> nicygan <[hidden email]> 于2020年12月24日周四 下午7:25写道:
>>
>>> dear  all:
>>>    我在checkpoint设置中,设置了
>>>
>>>     checkpointConfig.setMinPauseBetweenCheckpoints(180_000L)
>>>     但是好像并没有生效,
>>>     比如id=238的结束时间为17:13:30
>>>     但是id=239的开始时间也是17:13:30
>>>
>>>
>>>    我的理解id=239的开始时间至少应该是17:16:30
>>>
>>>    是我对这个参数理解有误吗?
>>>
>>>
>>> thanks
>>> by nicygan
>>>