Для заданий Flink с включенной контрольной точкой, когда она не удалась и попытаться восстановить с контрольной точки, возможно ли, что некоторые ресурсы не будут освобождены?и это создаст большое количество ресурсов, если восстановление происходит много раз.
код, подобный:
class Sinker extends SinkFunction {
private static RedisConnection obj = new RedisConnection();
}
Статический объект obj не может быть освобожден во многих заданиях.