Hi 从官方文档的配置[1] 来看,对于 handle failure 来说,默认是 fail,也就是说 request 失败了会导致作业失败的,可以尝试在 log 中看能否找到这个日志,或者显示的设置成 fail 看看。如果发现 handle failure 是 fail 的情况下不符合预期,可以想 Leonard 说的那样建立一个 issue 来追踪这个问题
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/elasticsearch.html#connector-options Best, Congxian Leonard Xu <[email protected]> 于2020年7月10日周五 上午11:33写道: > Hi, > 我理解作业应该失败才对,你本地可以复现吗?可以复现的话可以在社区建个issue。 > > Best, > Leonard Xu > > > 在 2020年7月10日,11:20,sunfulin <[email protected]> 写道: > > > > ,但是作业确实没失败。 > >
