mfaizanse opened a new pull request #33: URL: https://github.com/apache/incubator-streampipes/pull/33
### Purpose If the flink job is not found, then it means that it is cancelled or failed. So streampipes should continue to stop this PE from its in-memory storage and mark the whole pipeline as Stopped. ### Approach Changed in FlinkRuntime.java. Modified method discardRuntime() to also check if the job is present and its state is running then cancel the job, else if job is present but bot running then don't throw exception. Also change method getJobStatus() method to return job with any status. ### Remarks Fixes: https://issues.apache.org/jira/projects/STREAMPIPES/issues/STREAMPIPES-321 -- 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. For queries about this service, please contact Infrastructure at: [email protected]
