hdfs-protolib/src/main/java/com/streamsets/pipeline/stage/destination/hdfs/writer/RecordWriterManager.java
public void issueCachedEvents() throws IOException {
    Path closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(fs, closedPath);
    }
  }
public void issueCachedEvents() throws IOException {
    Path closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(fs, closedPath);
    }
  }
Produce events that were cached during the batch processing.