flink提交jar包时报连接不上BlobServer

2023-02-02 文章 孙冬燕
2023-02-02 19:21:21,288 WARN org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - Could not execute application: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed to execute job 'Flink Streaming Job'. at

Re: Flink消费消息队列写入HDFS

2023-02-02 文章 weijie guo
你好，可以使用FileSink，这个是基于新的sink API的。 Best regards, Weijie Howie Yang 于2023年2月2日周四 16:28写道： > Hey， > > > 最近想把消费日志写入到HDFS中，找这块的connector发现大部分都停留在使用 BucketingSink 的方式，这个好像是老版本的api了， > 这块官方推荐的最新的方式是什么呢？ > > > > > > > > > > > -- > > Best, > Howie

Flink消费消息队列写入HDFS

2023-02-02 文章 Howie Yang
Hey， 最近想把消费日志写入到HDFS中，找这块的connector发现大部分都停留在使用 BucketingSink 的方式，这个好像是老版本的api了， 这块官方推荐的最新的方式是什么呢？ -- Best, Howie