Sure, this feature has been implemented in FLINK-12364 [1], all you need do is
set the tolerable checkpoint failure numbers via like
env.getCheckpointConfig().setTolerableCheckpointFailureNumber(5);
[1] https://issues.apache.org/jira/browse/FLINK-12364
Best
Yun Tang
From:
Checkpoint will fail for some reasons，
Is there a way to make checkpoint fail a certain number of times and then
the job will fail automatically
SQL 如下:
INSERT INTO upsertTable
SELECT * FROM (
SELECT cnt0 as id, count(id) as cnt FROM
(SELECT id, count(*) as cnt0 FROM orderTable GROUP BY id)
GROUP BY cnt0
)
WHERE cnt > 0
输入数据:
1L, "hz"
2L, "hz"
3L, "hz"
1L, "hz"
当最后的WHERE 条件cnt >0(或者不加),结果是:
(true,1,3)
