0

因此，在使用 DataflowRunner 时，我们使用 filesToStage 方法将文件暂存到 GCS，但在 DirectRunner 中不会发生这种情况。有没有办法让 DirectRunner 将文件暂存到 GCS 并使用类似于 DataflowRunner 的文件，也许可以使用 ClassLoader 或其他方法？

4

1 回答 1

1

不，直接运行程序只是在本地运行，因此它不会将文件暂存到 GCS，它只是使用本地文件来运行软件。我最好的建议是编写一个在两个可能的位置查找文件的工具，通过定位文件来检测它是否在 dataflowrunner 或 directrunner 上运行

于 2018-05-09T00:15:08.790 回答