Hello, I have a flink streaming job that consumes data from RMQ source, process it and output it to RMQ sink.
I want to delete the RMQ source queue when cancelling the job but keep it if the job failed to resume processing it's data when the job is restarted. One solution is to override the cancel() function to delete the queue but it will be deleted in both cases. Is the a way to just delete it in case of cancelling the job? Thanks in advance!
