机器学习PAI这个 filePath 如何写?Caused by: java.lang.IllegalArgumentException: In CsvSourceBatchOp,Error in fromJson the paramValue : filePath
java.lang.RuntimeException: No data sinks have been created yet. A program needs at least one sink that consumes data. Examples are writing the data set or printing it.
at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:948) ~[flink-java-1.9.0.jar:1.9.0]
at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:926) ~[flink-java-1.9.0.jar:1.9.0]
at org.apache.flink.api.java.RemoteEnvironment.execute(RemoteEnvironment.java:167) ~[flink-java-1.9.0.jar:1.9.0]
以下为热心网友提供的参考意见
你好,PAI 的 filePath 可以是以下几种格式:
文件系统路径:在文件系统上,例如 /path/to/file。
HTTP 路径:在网络上,例如 http://example.com/path/to/file。
GCS 路径:在 GCS 上,例如 gs://bucket/path/to/file。
OSS 路径:在 OSS 上,例如 oss://bucket/path/to/file。
你可以根据自己的实际情况,选择适当的 filePath 格式。
具体用法可以参考 PAI 的文档:https://pai.corp.aliyun.com/docs/zh/user-guide/training-guide/train-file-path