String outputPath = "oss://<user-defined-oss-bucke
String outputPath = "oss:// / " StreamingFileSink sink = StreamingFileSink.forRowFormat( new Path(outputPath), new SimpleStringEncoder ("UTF-8") ).build(); outputStream.addSink(sink);
大佬，如果用flink的standlone的会话模式，把endpoint， accessKeyId， accessKeySecret，写入flink-conf.yaml中，lib中放入jindo-flink-sink-3.7.0.jar jindofs-sdk-3.7.0.jar，这2个jar包放在lib目录下可以吗？ outputPath = "oss://dataengine-bigdata-dw/yb/car_id=" + mapFunction.vin +"/data.txt" outputpath可以这样写吗，第一次加载，是全部写完，才会在阿里oss上显示吗，求大佬，大哥帮助下，谢谢
写回答
-
-
这两个 jar 是需要放在 Flink lib 目录下的。conf 可以命令行提交的时候设置，也可以写在配置文件里，都是 OK 的。
-
Flink 写文件有多种 API，文档示例里提供的是 streaming file sink API，output path 需要是一个目录，此时文件会在这个目录下滚动生成。如果希望写单个文件，最好是使用其他的 API。对于写 OSS 而言，因为 OSS 是对象存储，如果是写单个文件，那么通常在作业结束后才会在 OSS 上显示出来。（此答案整理自JindoData 用户交流群）
2022-08-01 10:32:34赞同 展开评论 打赏 -
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
阿里云EMR是云原生开源大数据平台，为客户提供简单易集成的Hadoop、Hive、Spark、Flink、Presto、ClickHouse、StarRocks、Delta、Hudi等开源大数据计算和存储引擎，计算资源可以根据业务的需要调整。EMR可以部署在阿里云公有云的ECS和ACK平台。
