Skip to content

Commit

Permalink
more logging while cancelling Flink jobs (#7289)
Browse files Browse the repository at this point in the history
Co-authored-by: Piotr Rudnicki <[email protected]>
  • Loading branch information
DeamonDev and Piotr Rudnicki authored Dec 6, 2024
1 parent 101f056 commit beb5d3c
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -199,7 +199,9 @@ class FlinkRestManager(
s"Trying to cancel $processName${deploymentId.map(" with id: " + _).getOrElse("")} which is not present or finished on Flink."
)
Future.successful(())
case single :: Nil => cancelFlinkJob(single)
case single :: Nil =>
logger.info(s"Cancelling Flink job with deploymentId: ${single.externalDeploymentId.getOrElse("")}.")
cancelFlinkJob(single)
case moreThanOne @ (_ :: _ :: _) =>
logger.warn(
s"Found duplicate jobs of $processName${deploymentId.map(" with id: " + _).getOrElse("")}: $moreThanOne. Cancelling all in non terminal state."
Expand Down Expand Up @@ -233,6 +235,7 @@ class FlinkRestManager(
deploymentId: ExternalDeploymentId,
savepointDir: Option[String]
): Future[SavepointResult] = {
logger.debug(s"Stopping Flink job: ${deploymentId.value}.")
client.stop(deploymentId, savepointDir)
}

Expand Down

0 comments on commit beb5d3c

Please sign in to comment.