apache / apache/beam

Removing Invalid JSON messages from PCollection before starting BigQueryIO Operations

Open
#20,309 0 comments 0 reactions 0 assignees View on GitHub
gcp improvement io java new feature P3
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

In a typical set up of Pub Sub and Cloud Dataflow, a pub sub subscriber might receive some messages that does not follow a valid json structure and the Big Query Insert operation fails to process these messages and the worker may gets terminated if the exception is not handled correctly.

The likelihood of receiving the invalid json messages are very less and the upstream component pushing messages on the Topic should have a validation at their end but this is not always the case and the application should be robust enough to survive even if there are wrong messages being pushed by the Upstreams. 

I have created an Enum which acts like a Predicate in Filter transform. This is very standard logic of validating Json and i would like to add this to the java SDK(and Python) in the Filter transform 

Imported from Jira [BEAM-9873](https://issues.apache.org/jira/browse/BEAM-9873). Original Jira may contain additional context.
Reported by: varun.sharma.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.