Custom origin having Java ScheduledExecutorService do not stop in background even if Pipeline is stopped

edit

Hi ,

I have developed Custom origin Scheduler , which uses JAVA ScheduledExecutorService to provide different information in different intervals periodically.

It works good but when during execution we are facing 2 problems

1- [Major ] Executor service remains running in background even when i do Force Stop Pipeline

2- When i do stop it remains in stopping mode and i need to go for force stop

I used solutions : 1- Stopping executor service forcefully in @destroy method but during Force stop I don't think destroy method is called as i can not see in logs.

Can some one please help me regarding this?

When we do forcestop which method is ideally called if I am implementing BasePushSource.

Regards, Ankit