Taskmanager PushGateway не очищался, когда работа заканчивалась

Question

На основе flink1.5 я запускаю задание flink stream и записываю метрику в Prometheus, которая выполняется в режиме кластера Yarn.В конце работы была удалена только задвижка менеджера, и задвижка не была удалена.Никакая информация об исключении не была выброшена во время запущенного процесса.Я обнаружил, что closeAsync taskmanagerRunner не был вызван.Я добавил кусок кода, и оба прохода были очищены.

    taskManager = startTaskManager(
        this.configuration,
        this.resourceId,
        rpcService,
        highAvailabilityServices,
        heartbeatServices,
        metricRegistry,
        blobCacheService,
        false,
        this);

    this.terminationFuture = new CompletableFuture<>();
    this.shutdown = false;
    // trigger delete 
    Runtime.getRuntime().addShutdownHook(new Thread(()->{
        metricRegistry.shutdown();
    }));