已解决。重改写了flink源码覆盖了这部分限制就可以了。 赵一旦 <hinobl...@gmail.com> 于2021年1月22日周五 上午10:17写道：
> 如题，为什么仅支持recoverableWriter，如果我使用的文件系统不支持怎么办呢，必须自定义sink吗？ > > > 我这边用的是一个公司自研的大型分布式文件系统，支持hadoop协议（但不清楚是否所有特性都支持），目前使用streamFileSink和FileSink貌似都无法正常写。 > > 不清楚是否有其他问题，至少当前是卡住在这个recoverable上了。 > > 报错是只有hdfs才支持recoverableWriter。 > > 有人知道如何解吗？ >
