[Java] context.Output within try catch can catch errors from downstream transforms · apache/beam

(3 条评论) (0 个反应) (0 位负责人)Java (4,097 个派生)batch import

good first issuejava

仓库指标

星标: (7,313 个星标)
PR 合并指标: (平均合并 6天) (30 天内合并 243 个 PR)

描述

Related to https://github.com/apache/beam/issues/20935

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

HL7v2IO

https://github.com/apache/beam/blob/48139dd7333a8c72ba8bc55bdc71ebb80211f768/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java#L365-L376

https://github.com/apache/beam/blob/3776a9992dd11116bed5a9576c6d846423be23d3/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java#L487-L498

FhirIO

https://github.com/apache/beam/blob/3776a9992dd11116bed5a9576c6d846423be23d3/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java#L602-L615

KafkaWriteSchemaTransformProvider https://github.com/apache/beam/blob/3776a9992dd11116bed5a9576c6d846423be23d3/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaWriteSchemaTransformProvider.java#L150-L166
BigQueryIO

https://github.com/apache/beam/blob/3776a9992dd11116bed5a9576c6d846423be23d3/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java#L2108-L2141

贡献者指南

研究方向: 检查链接的代码部分，并替换缺失的 try catch 块，采用适当的错误处理，以防止下游错误被吞没。
技术栈: java
领域: backendapi
议题类型: 缺陷
难度: 2
预计时间: 1-3 小时
活动状态: 活跃
清晰度: 基本清晰
前置要求: GitJava
新手友好度: 65