We are running a Spark streaming job that retrieves files from a directory (using textFileStream). One concern we are having is the case where the job is down but files are still being added to the directory. Once the job starts up again, those files are not being picked up (since they are not new or changed while the job is running) but we would like them to be processed. 1) Is there a solution for that? Is there a way to keep track what files have been processed and can we "force" older files to be picked up? 2) Is there a way to delete the processed files? ... View more