Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19909

Flink application in attach mode could not terminate when the only job is canceled

    XMLWordPrintableJSON

    Details

      Description

      Currently, the Yarn and Kubernetes application in attach mode could not terminate the Flink cluster after the only job is canceled. Because we are throwing ApplicationExecutionException in ApplicationDispatcherBootstrap#runApplicationEntryPoint. However, we are only checking ApplicationFailureException in runApplicationAndShutdownClusterAsync. Then we will go to fatal error handler which make the jobmanager directly exits. And it has no chance to deregister itself to the cluster manager(Yarn/Kubernetes). That means the jobmanager will be relaunched by cluster manager again and again until it exhausts the retry attempts.

       

      cc Kostas Kloudas, I am not sure is this an expected change? I think it could work in 1.11.

        Attachments

        1. log.jm
          134 kB
          Yang Wang

          Issue Links

            Activity

              People

              • Assignee:
                kkl0u Kostas Kloudas
                Reporter:
                fly_in_gis Yang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: