morhidi opened a new pull request, #208: URL: https://github.com/apache/flink-kubernetes-operator/pull/208
This is a workaround for https://issues.apache.org/jira/browse/FLINK-27569 . It creates random job result stores : ``` ls -al /tmp/flink/ha/job-result-store/basic-checkpoint-ha-example/ total 0 drwxr-xr-x 6 9999 9999 120 May 11 15:39 . drwxr-xr-x 3 9999 9999 60 May 11 14:52 .. drwxr-xr-x 2 9999 9999 60 May 11 15:32 1e080985-a3a9-4390-8567-134bc1f4c2d1 drwxr-xr-x 2 9999 9999 40 May 11 15:39 a6031ec7-ab3e-4b30-ba77-6498e58e6b7f drwxr-xr-x 2 9999 9999 60 May 11 15:11 b6fb2a9c-d1cd-4e65-a9a1-e825c4b47543 drwxr-xr-x 2 9999 9999 60 May 11 15:19 e569a5db-abb3-44ac-8169-545eeb46914a ``` It leaks the storage files on every upgrade, that is a know concern. Verify: - Run the basic-checkpoint-ha example - suspend the job - kill JM -> verify no jobs starts - resume the job - verify the job restored from checkpoint/savepoint -- 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]
