如何使用Google云端数据流播放其他文件？

我正在阅读Google Dataflow程序中的一些配置文件，并想知道如何对它们进行分级。目前我这样做，系统找不到它们。如何使用Google云端数据流播放其他文件？

FileReader filereader1 = new FileReader("config_1.csv"); 
FileReader filereader2 = new FileReader("config_2.csv");

config_1.csv和config_2.csv存储在./target/classes/org/model/examples/

我的行书是这样的：

mvn compile exec:java -Dexec.mainClass=org.model.examples.MyPipeline \ 
-Dexec.args="--runner=DataflowRunner \ 
    --project=mortgage-data-warehouse 
    --gcpTempLocation=gs://my-project-bucket/tmp \ 
    --inputFile=gs://my-project-bucket/Data/input.txt \ 
    --filesToStage=./target/classes/org/datamodel/examples/config_1.csv, ./target/classes/org/datamodel/examples/config_2.csv" \  
-Pdataflow-runner

我已经得到了错误

java.io.FileNotFoundException：config_1 .csv（系统找不到指定的文件）

我不知道这是否正确设置--filesToStage。

来源

2017-09-08 bignano

你能提供从错误的完整堆栈跟踪的并发症？在提交作业时，或者在尝试读取文件时Dataflow作业中，是否在本地计算机上获得了'FileNotFoundException'？ –

对于小的配置文件，它是更好的阅读，如已被写入该link从资源文件夹中的文件，并避免使用--filesToStage

来源

2017-09-15 15:23:38 bignano

如何使用Google云端数据流播放其他文件？

回答

相关问题