使用并行流处理具有大量数据的大量文件并将它们写入特定格式。这是代码: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 小时后被调用。这里有什么问题?是堆空间问题还是其他问题?我以前没有遇到过这种类型的问题。
添加回答
举报
0/150
提交
取消