title: temp files remain in GCS after a Dataflow job "succeeded"
body: <p>My team runs several hourly/daily Dataflow jobs, which mostly read from and write to GCS (that said, we have dozens of recurring Dataflow jobs scheduled to run within a day).
  Some jobs read the data from GCS which is produced by previous jobs.
  Roughly once or twice in a week, we face the following issue:</p>
  
  <ul>
  <li><p>Job A successfully runs, and writes its output to GCS at gs://A/output/.</p></li>
  <li><p>(the main issue which takes places between Job A and Job B we identified is described in the next paragraph).</p></li>
  <li><p>Job B reads from gs://A/output to process some data, but throws an exception because either a temp file was removed while the job was running or due to temp files the keys in the data are no longer unique (e.g., if Job B creates a MapView of the data above, this occurs).</p></li>
  </ul>
  
  <p>So the reason, as far as we were able to debug is the following:</p>
  
  <ul>
  <li><p>By the time Job A finishes (according to its pipeline status, e.g.), all 'temp' files under gs://A/output/ should have been renamed to the file name(s) specified by the job.</p></li>
  <li><p>Yet some of these temp files are lingering around for a few minutes after Job A finishes -- sometimes, we even see those temp files a few hours after the completion of Job A, so we often have to remove them manually.</p></li>
  <li><p>For instance, we only see one or two temp files lingering around out of ~7,500 files in the directory, and they often go away within an hour, but sometimes they stay for a few hours. </p></li>
  </ul>
  
  <p>We are wondering about the following:</p>
  
  <ul>
  <li><p>Is our understanding correct that all "temp" files in GCS output directory should be renamed before Job A "finishes" (e.g., on the monitoring UI it says it succeeded, and it has stopped worker pool, etc.)? In other words, completion of a job is an indicator that the temp files are gone?</p>
  
  <ul>
  <li><p>If yes, is it a bug that we see temp files much after the job is completed?</p></li>
  <li><p>If no, how can we (the user) know that the job is "really" completed in the sense that its output directory does not contain temp files? (Should we check it with our own file pattern matching script or something like that?)</p></li>
  </ul></li>
  </ul>
  
  <p>I did some search with GCS and Dataflow as keywords, but found nothing close to the issue we are having -- but I might have missed something, so any help will be really appreciated!</p>