Aryankn29 opened a new pull request, #39124:
URL: https://github.com/apache/beam/pull/39124
Fixes #39101
This separates successful Beam output emission from try/catch blocks that
handle local read/fetch/parse failures. This prevents errors from downstream
fused transforms from being accidentally caught and reported as source-side
failures.
Changes:
* Move HL7v2 successful outputs outside the fetch try/catch blocks.
* Move FHIR successful output outside the fetch try/catch block.
* Move BigQuery row output outside the ParseException try/catch while
preserving existing bad record routing.
* Leave already-safe patterns unchanged.
Tests:
* git diff --check
* ./gradlew :sdks:java:io:google-cloud-platform:compileJava --no-daemon
--console=plain
Targeted tests attempted:
* ./gradlew :sdks:java:io:google-cloud-platform:test --tests
org.apache.beam.sdk.io.gcp.healthcare.HL7v2IOTest --no-daemon --console=plain
* Failed locally due to Google DefaultCredentialsProvider IOException.
* ./gradlew :sdks:java:io:google-cloud-platform:test --tests
org.apache.beam.sdk.io.gcp.healthcare.FhirIOTest --no-daemon --console=plain
* Failed locally due to Google DefaultCredentialsProvider IOException and
one local assertion failure.
* ./gradlew :sdks:java:io:google-cloud-platform:test --tests
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIOReadTest --no-daemon
--console=plain
* 31/33 passed; 2 failed locally with Windows FileSystemException.
--
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]
