[BEAM-11940] JsonToRow can catch errors in downstream transforms

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Affects Version/s: 2.26.0, 2.27.0, 2.28.0
• Component/s: sdk-java-core
• Assignee: Unassigned
• Reporter: Reza ardeshir rokni
• Created: 09/Mar/21 15:01
• Updated: 04/Jun/22 20:11

Description

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

Issue Links

• is related to: BEAM-11942 Add an errorprone check to detect try-catch blocks around countext.output