flink读取socket问题

Question

我在flink作业中读取socket数据，进行简单的统计，然后我开启了checkpoint，保存到hdfs里面，我发现当我运行着的时候，手动去关闭socket链接，flink作业就会退出，然后checkpoint中的ck-*目录会被删除，但是如果我没有关闭socket，仅仅是因为flink内部出错导致超过重启次数（设置为2）而挂掉了，这个目录却不会被删除，为什么关闭socket导致的作业挂掉会删除checkpoint的信息呢？

Answer 1

Michael_PK 2020-06-11 17:33:04

socket关闭会引起重跑策略，如果超了那肯定就失败，如果开启了retain，checkpoint应该是有的

• 提问者 Jackson_xky #1

  我设置了retain，就是如果主动关闭socket，flink作业会立马退出，并不会重启，并把checkpoint里面的ck-*删除。如果没关闭socket，只是flink作业内部出现问题，就会重启，那个目录就不会被删除

• Michael_PK 回复 提问者 Jackson_xky #2

  分两步说:socket关闭我觉得你只要重启策略OK它会重试的，不然就没容错了。有一半我用1.10测试没发现这个问题