How much time has passed between the requests? (You can only query the
status for about 5 minutes)
On 6/29/2021 6:37 AM, Rainie Li wrote:
Thanks for the context Chesnay.
Yes, I sent both requests to the same JM.
Best regards
Rainie
On Mon, Jun 28, 2021 at 8:33 AM Chesnay Schepler <ches...@apache.org
<mailto:ches...@apache.org>> wrote:
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