Ordinarily this happens because the status request is sent to a
different JM than the one who received the request for creating a savepoint.
The meta information for such requests is only stored locally on each JM
and neither distributed to all JMs nor persisted anywhere.
Did you send both requests ( the ones for creating a savepoint and one
for querying the status) to the same JM?
On 6/26/2021 11:18 PM, Rainie Li wrote:
Hi Flink Community,
I found this error when I tried to create a savepoint for my flink
job. It's in version 1.9.
{
"errors": [
"Operation not found under key:
org.apache.flink.runtime.rest.handler.job.AsynchronousJobOperationKey@57b9711e"
]
}
Here is error from JM log:
2021-06-21 06:49:50,195 ERROR
org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler
- Exception occurred in REST handler: Operation not found under key:
org.apache.flink.runtime.rest.handler.job.AsynchronousJobOperationKey@56675052
2021-06-21 06:50:50,023 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Checkpoint
47281 of job 8de31918b2f2d983eee0d7f988a8f95a expired before completing.
Any idea what could cause it and how to find more debugging info?
Appreciated for any suggestions.
Thanks
Best regard
Rainie
