请问cancel的任务能够恢复running状态吗？

[陈佳豪 <ja...@yeah.net>]

hi
我目前测试flink restapi 指定savepointpath来恢复任务发现会重新触发创建一个新的任务原有的任务还是cancel状态，请问有办法恢复原有cancel状态的任务为running吗？

Re: 请问cancel的任务能够恢复running状态吗？

[yidan zhao <hi...@gmail.com>]

话说我也有个问题，stop后基于savepoint恢复 不同于先savepoint，然后cancel后基于savepoint恢复？

Weihua Hu <hu...@gmail.com> 于2023年1月5日周四 10:38写道：
>
> Hi，
>
> 简单来说是不能，已经 cancel 的 job 状态不能恢复到 running 状态。用 savepoint 恢复的任务是新的 job。
>
> 这个问题的背景是什么呢？什么情况下需要将已经 cancel 的 job 恢复呢？
>
>
> Best,
> Weihua
>
>
> On Fri, Dec 30, 2022 at 5:12 PM 陈佳豪 <ja...@yeah.net> wrote:
>
> > hi
> > 我目前测试flink restapi
> > 指定savepointpath来恢复任务发现会重新触发创建一个新的任务原有的任务还是cancel状态，请问有办法恢复原有cancel状态的任务为running吗？

Re: 请问cancel的任务能够恢复running状态吗？

[Weihua Hu <hu...@gmail.com>]

Hi，

简单来说是不能，已经 cancel 的 job 状态不能恢复到 running 状态。用 savepoint 恢复的任务是新的 job。

这个问题的背景是什么呢？什么情况下需要将已经 cancel 的 job 恢复呢？


Best,
Weihua


On Fri, Dec 30, 2022 at 5:12 PM 陈佳豪 <ja...@yeah.net> wrote:

> hi
> 我目前测试flink restapi
> 指定savepointpath来恢复任务发现会重新触发创建一个新的任务原有的任务还是cancel状态，请问有办法恢复原有cancel状态的任务为running吗？

回复：请问cancel的任务能够恢复running状态吗？

[DannyLau <ch...@163.com>]

退订
| |
刘朝兵
|

Re: checkpoint首次触发时间疑问

[Jiangang Liu <li...@gmail.com>]

首次快照时间是一个随机数，计算逻辑如下。你可以尝试设置下execution.checkpointing.min-pause

private long getRandomInitDelay() {
    return ThreadLocalRandom.current().nextLong(minPauseBetweenCheckpoints,
baseInterval + 1L);
}


aiden <18...@163.com> 于2023年1月5日周四 14:06写道：

> hello，我们需求是要将kafka数据落到hive中，为了避免hive小文件问题，采用了一小时checkpoint，具体参数为：
>
> bsEnv.enableCheckpointing(3600000);
> bsEnv.setStateBackend(new HashMapStateBackend());
>
> bsEnv.getCheckpointConfig().setCheckpointStorage("hdfs://xxx/user/flink/checkpoint/serverlog/hc");
>
> 但在执行时发现首次checkpoint并没有按照一小时触发.
> 作业执行时间为：2023-01-05 10:04:17，但首次checkpoint时间为：2023-01-05 10:34:19
> checkpoint首次触发时间是和什么有关？以及通过什么参数可以设置吗？
>

checkpoint首次触发时间疑问

[aiden <18...@163.com>]

hello，我们需求是要将kafka数据落到hive中，为了避免hive小文件问题，采用了一小时checkpoint，具体参数为：

bsEnv.enableCheckpointing(3600000);
bsEnv.setStateBackend(new HashMapStateBackend());
bsEnv.getCheckpointConfig().setCheckpointStorage("hdfs://xxx/user/flink/checkpoint/serverlog/hc");

但在执行时发现首次checkpoint并没有按照一小时触发.
作业执行时间为：2023-01-05 10:04:17，但首次checkpoint时间为：2023-01-05 10:34:19
checkpoint首次触发时间是和什么有关？以及通过什么参数可以设置吗？