You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@flink.apache.org by GitBox <gi...@apache.org> on 2026/10/02 20:36:47 UTC
[GH] (flink-kubernetes-operator/fix/session-cluster-deletion-fail-open): Workflow run "Flink Kubernetes Operator CI" failed!
The GitHub Actions job "Flink Kubernetes Operator CI" on flink-kubernetes-operator.git/fix/session-cluster-deletion-fail-open has failed.
Run started by GitHub user spuru9 (triggered by spuru9).
Head commit for run:
1a4ab8468506c528cb690c9b20693812b21791c8 / Purushottam Sinha <ps...@confluent.io>
[FLINK-40542] Block session cluster deletion when running jobs cannot be determined
SessionReconciler.getNonTerminalJobs returned Set.of() on any failure to
query the cluster. cleanupInternal treats an empty set as "no running jobs,
safe to delete", so a transient JobManager outage during deletion of a
session cluster with block-on-unmanaged-jobs enabled (the default) silently
deleted the cluster while unmanaged jobs were still running - stopping them
without a checkpoint, with only a WARN.
Return Optional<Set<JobID>> so an indeterminate result (empty Optional) is
distinguishable from a determined "no jobs" (present, empty set).
cleanupInternal now blocks deletion and emits a CleanupFailed event on the
indeterminate case, mirroring the block-on-session-jobs branch. Also close
the RestClusterClient via try-with-resources and bound the jobs request with
the Flink client timeout instead of an unbounded get().
Generated-by: Claude Code (Claude Opus 4.8)
Report URL: https://github.com/apache/flink-kubernetes-operator/actions/runs/33680230577
With regards,
GitHub Actions via GitBox