如何解决Flink-StreamingFileSink到s3无法从上一个快照恢复java.io.FileNotFoundException
我有一个简单的Flink作业(flink版本1.8.3),该作业具有一个接收器,该接收器每10分钟写入一个s3存储桶。
当我停止工作并从上一个快照重新启动它时,我经常会遇到此错误,这使我无法正确继续工作
powershell.exe "Import-module ActiveDirectory -force
Import-module DBATools -force
Import-module Person -force
Get-Person 'server' 'db'"
我已在s3存储桶中签入,并且该临时文件不存在。 看起来好像是这样,当作业停止时,在写入文件时出现某种错误,而当我重新启动作业时,它又以某种方式再次尝试查找该文件,但它不在那里?
如何避免出现此问题?有没有办法忽略丢失的文件?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。