damccorm opened a new issue, #20935:
URL: https://github.com/apache/beam/issues/20935
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](https://issues.apache.org/jira/browse/BEAM-11940). Original Jira
may contain additional context.
Reported by: [email protected].
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
