我们正在使用flink处理输入事件,并使用streamingfilesink将流式处理作业的o/p聚合并写入s3,但每当我们尝试从保存点还原作业时,还原都会失败,并出现缺少部分文件错误。根据我的理解,s3删除了那些部分(间歇)文件,在s3上再也找不到了。是否有一个解决方法,以便我们可以使用s3作为一个Flume?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!