apache/beam

JsonToRow can catch errors in downstream transforms

已關閉

#20,935 建立於 2022年6月4日

 (2 則留言) (0 個反應) (1 位負責人)Java (4,097 個分叉)batch import
P3bugcoregood first issuejava

倉庫指標

星標
 (7,313 顆星)
PR 合併指標
 (平均合併 6天) (30 天內合併 243 個 PR)

描述

JsonToRow :

  |try {| | | | | |output.get(PARSED_LINE).output(jsonToRow(objectMapper(), element));| | | | | |} catch (Exception ex) {|

Can catch errors thrown downstream with runners that have fusion. This can be confusing as it can appear that the issue happens in the parse operation , when its really happening in a transform further down the DAG. This is made worse as different runners can show different behaviour in this situation.

 

Replace with try{i = parse}catch{}  if i not null output

Imported from Jira BEAM-11940. Original Jira may contain additional context. Reported by: rarokni@gmail.com.

貢獻者指南