0

我正在尝试使用 pyspark 中的 elasticsearch hadoop 包进行更新操作。它在文档上说,如果没有找到数据,则会引发异常。在 pyspark 中忽略此异常的最佳方法是什么?或者是否可以通过 python elasticsearch API 提供的诸如 raise_on_exception=False, raise_on_error=False 之类的传递?谢谢!

4

1 回答 1

0

终于在这里得到了答案:https ://discuss.elastic.co/t/how-to-ignore-exceptions-when-bulk-update-with-pyspark-if-doc-doesnt-exist/90739/2

“当错误发生时,没有办法抑制错误。如果在执行更新时缺少某个值,则连接器无能为力,只能使任务失败。”

于 2017-06-27T13:23:59.537 回答