我在amazon EMR上使用Flink,并希望将我的流水线结果流式传输到s3存储桶中。我使用的是Flink版本=> 1.11.2 这是代码片段,展示了代码现在的样子,变量: val outputPath = new Path("s3://test/flinkStreamTest/failureLogs:528)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.
背景
org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Could not find a file system implementationfor scheme 's3'.The scheme is not directly supported by Flink and no Hadoop f