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



Reply via email to