dalelane opened a new pull request, #1199:
URL: https://github.com/apache/flink-kubernetes-operator/pull/1199
## What is the purpose of the change
Flink 2.3 gives every application-mode execution an ApplicationResultStore,
which defaults to
{high-availability.storage-path}/application-result-store/{ha.cluster-id}.
That path is consistent across deployments (and not included in HA cleanup) so
entries written by a terminated application outlive the upgrade that replaced
it.
SessionDispatcherLeaderProcess recovers dirty results unkeyed, so the
replacement cluster picks up the previous deployment's entry, and
Dispatcher#maybeSubmitApplicationInApplicationMode then deliberately submits
nothing when execution.shutdown-on-application-finish is false. This results in
healthy JobManagers with no jobs.
## Brief change log
This commit makes the storage path unique on each cluster launch so nothing
stale can be recovered.
## Verifying this change
Added a unit test that recreates the scenario
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changes to the `CustomResourceDescriptors`:
no
- Core observer or reconciler logic that is regularly executed: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? not applicable
##### Was generative AI tooling used to co-author this PR?
- [ ] Yes (please specify the tool below)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
