Savepoint status check fails with error Operation not found under key

[anaray]

Hi,

I am using flink 1.7.0 and checking the status of the savepoint fails with
error

{
    "errors": [
        "Operation not found under key:
org.apache.flink.runtime.rest.handler.job.AsynchronousJobOperationKey@57b9711e"
    ]
}

I have automated these savepoint creation and checking status using ansible plays. So creation of savepoint is the first play followed by checking status play which uses the  trigger_id, got from first.

In my initial debugging I think even though trigger_id was created, it was not populated in the completedOperationCache, when my second ansible play was checking for it. I am referring to below code in AbstractAsynchronousOperationHandlers.java

try {
        operationResultOrError = completedOperationCache.get(key);
     } catch (UnknownOperationKeyException e) {
                return FutureUtils.completedExceptionally(
                        new NotFoundException("Operation not found under key: " + key, e));
     }

Do you think there is a possibility that completedOperationCache takes some time to get populated ?


I am using 1.7.0 documentation
https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/rest_api.html#jobs-jobid-savepoints-triggerid

Please let me know, if you have seen this issue before?

Thanks,
anaray



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Yun Tang]

Hi Anaray

Did you use /jobs/:jobid/savepoints/744e6b6488212b80deab51486620e348 to query the savepoint status and will Flink always return the same result to you when you query it later again? What's more, have you ever checked the web UI to see whether that savepoint ever triggered. If possible, you could search job manager log during that time when you trigger the savepoint and share it here.

Best

Yun Tang

---

From: anaray <[hidden email]>
Sent: Wednesday, June 12, 2019 5:35
To: [hidden email]
Subject: Savepoint status check fails with error Operation not found under key

 

Hi,

I am using flink 1.7.0 and checking the status of the savepoint fails with
error

{
    "errors": [
        "Operation not found under key:
org.apache.flink.runtime.rest.handler.job.AsynchronousJobOperationKey@57b9711e"
    ]
}


I started a savepoint using /jobs/:jobid/savepoints REST api, which returned
me as trigger-id
request-id": "744e6b6488212b80deab51486620e348", but when I called
/jobs/:jobid/savepoints/:triggerid using above request-id, it failed with
"Operation not found under key"

I referred 1.7.0 documentation
https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/rest_api.html#jobs-jobid-savepoints-triggerid

Please let me know, if you have seen this issue before?

Thanks,
anaray



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/