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

Missing info output for when filtering JobGraphs based on their persisted JobResult

    XMLWordPrintableJSON

Details

    Description

      We have the case where we don't see (in the logs) a job being registered in the {[JobResultStore}} after it reached a globally-terminal state (HA-mode enabled).

      We would have expected the job to be picked up again for recovery after the JM failover which didn't happen as well. We're missing a debug statement here that would help us identify the case that the job was actually registered in the JobResultStore but the log message afterwards isn't printed.

      We could fix that by adding some info logs for the filtering mechanism when recovering the jobs as a else branch in SessionDispatcherLeaderProcess:149 (and in JobDispatcherLeaderProcessFactoryFactory accordingly)

      Attachments

        Issue Links

          Activity

            People

              snuyanzin Sergey Nuyanzin
              mapohl Matthias Pohl
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: