azure-lib/src/main/java/com/streamsets/pipeline/stage/destination/datalake/writer/DataLakeGeneratorManager.java
public void issueCachedEvents() throws IOException {
    String closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(closedPath);
    }
  }
public void issueCachedEvents() throws IOException {
    String closedPath;
    while((closedPath = closedPaths.poll()) != null) {
      produceCloseFileEvent(closedPath);
    }
  }
Produce events that were cached during the batch processing.