Fix FileNotFound in realtime nodes

Fix race in ingestion that can cause FNF,
Properly check for partitionNum
shutdown persistExecutor