Java 8：并行流等待所有线程完成任务

Question

使用并行流处理具有大量数据的大量文件并将它们写入特定格式。这是代码：public static void main(String[] args) throws Exception {   mergeController.compactFiles();   mergeController.writeMergedFlag();}private void compactFiles() {  Set<String> events = this.listSubDirectoryNames(inputDir);  events.parallelStream().forEach(event -> writeEvent(event, eventSchemaMap.get(event), this.configuration));}这些方法不返回任何内容，因为它们只是在写入文件。我看到writeMergedFlag()主要是在运行该过程 1.5 小时后被调用。这里有什么问题？是堆空间问题还是其他问题？我以前没有遇到过这种类型的问题。