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 (将#修改为@)